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             while (!end) {
  15                 String rline = client.receiveMsg();
  16                 if (rline.equals(".")) {
  17                                         end = true;
  18                 }
  19                 System.out.println(Thread.currentThread().getName() + " a recu " + rline);
  20             }
  21         }
  22         catch (IOException e) {
  23             System.err.println("IOException: " + e);
  24             e.printStackTrace();
  25         }
  26     }
  27 }