TD2/client/ThreadClientReceive.java

   1 import java.util.concurrent.ThreadLocalRandom;
   2 import java.io.*;
   3
   4 public class ThreadClientReceive implements Runnable {
   5     private SocketClient client;
   6
   7     ThreadClientReceive(SocketClient c) {
   8         client = c;
   9     }
  10
  11     public void run() {
  12         try {
  13             boolean end = false;
  14             //FIXME: Not exiting properly from that loop!
  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);
  21             }
  22         }
  23         catch (IOException e) {
  24             System.err.println("IOException: " + e);
  25             e.printStackTrace();
  26         }
  27     }
  28 }