alartigu/ChatApp-AL-NM
1
0
Fork 0
Code Issues Pull requests Releases Wiki Activity

Phase test TCP envoi OK historique KO

Browse source
This commit is contained in:
Nabil Moukhlis 2020-12-09 09:52:33 +01:00
parent 124735fcc9
commit 616067cd20
4 changed files with 12 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

BIN
Implementation/src/RunnerTCPEcoute.class
View file

Binary file not shown.

BIN
Implementation/src/RunnerTCPEnvoi.class
View file

Binary file not shown.

BIN
Implementation/src/TCPEchange.class
View file

Binary file not shown.

15
Implementation/src/TCPEchange.java
View file

@ -24,9 +24,18 @@ public class TCPEchange {
System.out.println("Demmarrage d'une session de clavardage"); System.out.println("Demmarrage d'une session de clavardage");
Socket s = new Socket(User2.getIp(),5000); Socket s = new Socket(User2.getIp(),5000);
System.out.println("Socket de demarrage d'une session cree"); System.out.println("Socket de demarrage d'une session cree");
ExecutorService exec = Executors.newFixedThreadPool(1000); //ExecutorService exec = Executors.newFixedThreadPool(1000);
exec.submit(new RunnerTCPEcoute(s,app)); Thread t1 = new Thread(new RunnerTCPEcoute(s,app));
exec.submit(new RunnerTCPEnvoi(s,app,User2,false)); 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");
} }