diff --git a/Implementation/src/RunnerTCPEcoute.class b/Implementation/src/RunnerTCPEcoute.class index 50b599d..d6db733 100644 Binary files a/Implementation/src/RunnerTCPEcoute.class and b/Implementation/src/RunnerTCPEcoute.class differ diff --git a/Implementation/src/RunnerTCPEnvoi.class b/Implementation/src/RunnerTCPEnvoi.class index 0a09565..b036dd4 100644 Binary files a/Implementation/src/RunnerTCPEnvoi.class and b/Implementation/src/RunnerTCPEnvoi.class differ diff --git a/Implementation/src/TCPEchange.class b/Implementation/src/TCPEchange.class index 353e4bb..91881f5 100644 Binary files a/Implementation/src/TCPEchange.class and b/Implementation/src/TCPEchange.class differ diff --git a/Implementation/src/TCPEchange.java b/Implementation/src/TCPEchange.java index beb9154..325a90f 100644 --- a/Implementation/src/TCPEchange.java +++ b/Implementation/src/TCPEchange.java @@ -24,9 +24,18 @@ public class TCPEchange { System.out.println("Demmarrage d'une session de clavardage"); Socket s = new Socket(User2.getIp(),5000); System.out.println("Socket de demarrage d'une session cree"); - ExecutorService exec = Executors.newFixedThreadPool(1000); - exec.submit(new RunnerTCPEcoute(s,app)); - exec.submit(new RunnerTCPEnvoi(s,app,User2,false)); + //ExecutorService exec = Executors.newFixedThreadPool(1000); + Thread t1 = new Thread(new RunnerTCPEcoute(s,app)); + Thread t2 = new Thread(new RunnerTCPEnvoi(s,app,User2,false)); + t1.start(); + t2.start(); + try { + t1.join(); + t2.join(); + }catch(InterruptedException e) { + System.out.println("Un thread s'est arrete brusquement"); + } + System.out.println("Tout s'est passé crème"); }