Commit | Line | Data |
---|---|---|
2c648f75 | 1 | import java.util.concurrent.ThreadLocalRandom; |
e018d1ec | 2 | import java.io.*; |
2c648f75 JB |
3 | |
4 | public class ThreadClientReceive implements Runnable { | |
5 | private SocketClient client; | |
2c648f75 JB |
6 | |
7 | ThreadClientReceive(SocketClient c) { | |
8 | client = c; | |
9 | } | |
10 | ||
2c648f75 | 11 | public void run() { |
e018d1ec JB |
12 | try { |
13 | boolean end = false; | |
ef258436 | 14 | //FIXME: Not exiting properly from that loop! |
e018d1ec JB |
15 | while (!end) { |
16 | String rline = client.receiveMsg(); | |
17 | if (rline.equals(".")) { | |
18 | end = true; | |
19 | } | |
20 | System.out.println(Thread.currentThread().getName() + " a recu " + rline); | |
2c648f75 | 21 | } |
2c648f75 | 22 | } |
e018d1ec JB |
23 | catch (IOException e) { |
24 | System.err.println("IOException: " + e); | |
25 | e.printStackTrace(); | |
26 | } | |
2c648f75 JB |
27 | } |
28 | } |