TD1: Refactor the client side code.

[TD_SR.git] / TD2 / client / ThreadClientReceive.java

import java.util.concurrent.ThreadLocalRandom;
import java.io.*;

public class ThreadClientReceive implements Runnable {
    private SocketClient client;

    ThreadClientReceive(SocketClient c) {
        client = c;
    }

    public void run() {
        try {
            boolean end = false;
            while (!end) {
                String rline = client.receiveMsg();
                if (rline.equals(".")) {
					end = true;
                }
                System.out.println(Thread.currentThread().getName() + " a recu " + rline);
            }
        }
        catch (IOException e) {
            System.err.println("IOException: " + e);
            e.printStackTrace();
        }
    }
}