Lancer plusieurs fois la meme thread

Version imprimable

25/09/2007, 01h45
andromeda

Lancer plusieurs fois la meme thread
Bonjour,

Je souhaite lancer par exemple 5 thread de suite, comment faire?

J'ai cree ma classe qui derive de thread et la methode run mais lorsque je fais
Code:

1 2 3 4 5 6 for (int i = 0; i < 5; i++) { new Clients().start(); Thread.sleep(30); }
au lieu de me le lancer 5 fois , il me le lance des fois 7 fois , des fois 9 fois , c'est aleatoire.

Merci de votre aide.

J'ai tenté ceci:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
 
for (int i = 0; i < 10; i++) {
      			Clients client = new Clients();
      			Thread t = new Thread(client);
      			t.start();
 
      		  try {
      		      t.join();
      		    } catch (InterruptedException e) {
      		      e.printStackTrace();
      		    }
      		}

C'est un peu mieux, parfois il m'en fait 11 et parfois 10

quelqu'un a une idee pour avoir exactement le nombre de thread que je veux ?

Merci de votre aide.

25/09/2007, 09h10
adiGuba

Salut,

Citation:

Envoyé par andromeda

au lieu de me le lancer 5 fois , il me le lance des fois 7 fois , des fois 9 fois , c'est aleatoire.

On pourrait voir le code de ta classe Clients ?

a++

PS : dans le deuxième code, à quoi ca sert de lancer un thread si c'est pour faire un join() derrière ???

le code n'a rien a voir avec ca je pense, c'est au niveau du thread.
meme si le thread a un code minimum, pour afficher toto ca fait la meme chose.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
import java.io.IOException;
import java.net.Socket;
import java.util.Date;
 
import kConst.Constantes;
 
public class Clients extends Thread {
	private Socket client;  	
 
	public Clients(){
        try{                    
	       	System.out.println(new Date()+ "==> Tentative de connexion au serveur "+ Constantes.host + " port "+ kConst.Constantes.PORT);
	       	client = new Socket(Constantes.host, Constantes.PORT);
	    }
      	catch ( IOException e )
	    {
	    	System.out.println(new Date()+ "==> Impossible de se connecter au serveur ");	       		
	    }      		
 
    } // !constructeur
 
	public void run(){
		try{
 
	    	TrameVehicule tramevehicule = new TrameVehicule(this.client);	    	
 
	    }catch (Exception e){System.err.println(e);}
	  }// ! run() method
}// ! Clients class

Quelqu'un a deja lance plusieurs fois la meme thread ?

25/09/2007, 11h54
adiGuba

Citation:

Envoyé par andromeda

le code n'a rien a voir avec ca je pense, c'est au niveau du thread.
meme si le thread a un code minimum, pour afficher toto ca fait la meme chose.

Et bien fournit nous un code minimum où le problème se reproduit, que l'on puisse tester de notre coté...

Car là il n'y a pas de raison que les threads s'exécutent plusieurs fois...

a++
25/09/2007, 12h12
andromeda

je lai mis plus haut

a la place de
TrameVehicule tramevehicule = new TrameVehicule(this.client);
il faut mettre
System.out.println("toto");

Merci.

Citation:

Envoyé par andromeda

a la place de
TrameVehicule tramevehicule = new TrameVehicule(this.client);
il faut mettre
System.out.println("toto");

C'est à dire quelque chose comme cela :
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 public class Clients extends Thread { public void run() { System.out.println("toto"); } public static void main(String[] args) throws InterruptedException { for (int i = 0; i < 5; i++) { new Clients().start(); Thread.sleep(30); } } }
Ce qui me donne comme résultat :
Code:

1 2 3 4 5 toto toto toto toto toto
Bref tout est normal !

Bon courage...

a++

Ce n'est pas le meme code que toi que j'ai; moi il me l'affiche neuf fois.

moi j'appel clients dans ma classe principal en creant la thread

code principal:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
public class SimulatorKuantic {
 
    public static void main(String[] args) {     
 
      	try {      		      	
      		for (int i = 0; i < 10; i++) {
      			Clients client = new Clients();
      			Thread t = new Thread(client);
      			t.start();
 
      		  try {
      		      t.join();
      		    } catch (InterruptedException e) {
      		      e.printStackTrace();
      		    }
      		}
 
      	}  catch (Exception e){System.out.println("SimulatorKuantic main : "+e);}	 
 
      	System.out.println("Traitement terminé");
	}
 
}

et la classe client:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
 
import java.io.IOException;
import java.net.Socket;
import java.util.Date;
 
import kConst.Constantes;
 
public class Clients extends Thread {
	private Socket client;  	
 
	public Clients(){
        try{                    
	       	System.out.println(new Date()+ "==> Tentative de connexion au serveur "+ Constantes.hostGPS + " port "+ kConst.Constantes.PORT);
	       	client = new Socket(Constantes.hostGPS, Constantes.PORT);
	    }
      	catch ( IOException e )
	    {
	    	System.out.println(new Date()+ "==> Impossible de se connecter au serveur GPS ");	       		
	    }      		
 
    } // !constructeur
 
	public void run(){
		try{
 
	    	//TrameVehicule tramevehicule = new TrameVehicule(this.client);
			System.out.println("Toto");
 
	    }catch (Exception e){System.err.println(e);}
	  }// ! run() method
}// ! Clients class

Ou est le mprobleme ?
tu as mis le main dans la thread ?

Merci de votre aide.

25/09/2007, 13h04
adiGuba

Citation:

Envoyé par andromeda

Ce n'est pas le meme code que toi que j'ai;

C'est un peu pour cela que je te demandais ton code exact... :?

Citation:

Envoyé par andromeda

moi il me l'affiche neuf fois.

Donc il en manque un ! Alors que dans la description du problème tu disais avoir plus de thread que ce que tu n'en lancais...

:arrow: As-tu une exception dans tes traces qui pourrait expliquer qu'un des threads ne s'exécute pas ?

Sinon je réitère ma question : à quoi ca sert de lancer un thread si c'est pour faire un join() derrière ???

Et pourquoi fais tu new Thread(client) alors que client est déjà un thread ???

a++
25/09/2007, 13h07
andromeda

en fait le probleme , d'apres ce que j'ai pu constate , les thread se lance un peu au hasard,

par exemple au lieu de lancer les thread dans l'ordre 1,2,3,4,5 il les lance
dans un ordre 1,3,5,4

il faudrait que je puisse dire a java de les executer une par une en attendant que la precedente se termine.

est ce que c'est possible de lui dire ca ?

lancement de la thread 1
quand thtread1 se termine, lancer thread 2, etc ... jusqua la 5

Merci de votre aide.
25/09/2007, 13h14
adiGuba

Citation:

Envoyé par andromeda

lancement de la thread 1
quand thtread1 se termine, lancer thread 2, etc ... jusqua la 5

C'est du séquentiel !!! Pourquoi faire des threads dans ce cas là ?

a++
25/09/2007, 15h05
Faiche

Je te dirais bien de regarder du coté des ThreadPoolExecutor mais vu comme tu traites les thread, ça risque de te compliquer la tache plus qu'autre chose.

en fait c'est pour faire un tests de charge, c'est a dire lancer des milliers de thread qui se connecte a un serveur.

mais en mettant le joint ca a l'air de marcher, je suis oblige de mettre des joint pour eviter des effet de bord du a la connection au serveur:

ci-joint mon code:

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
 
import java.io.IOException;
import java.net.Socket;
import java.util.Date;
 
import kConst.Constantes;
 
 
public class SimulatorKuantic extends Thread {
 
	private Socket client;
 
	public void run(){		
 
		//Temporisation de 30 millisecond
		try {
			Thread.sleep(30); // ms
		} catch (InterruptedException e) {
			System.out.println("Thread.sleep probleme!\n");
			return;
		}
 
		//Connexion au serveur
		try{                    
	       	System.out.println(new Date()+ "==> Tentative de connexion au serveur "+ Constantes.hostGPS + " port "+ kConst.Constantes.PORT);
	       	client = new Socket(Constantes.hostGPS, Constantes.PORT);
	    }
      	catch ( IOException e )
	    {
	    	System.out.println(new Date()+ "==> Impossible de se connecter au serveur GPS ");	       		
	    }   
 
      	//Envoie de la trame au serveur
		try{	        		      		      	
	    	TrameVehicule tramevehicule = new TrameVehicule(this.client);			
 
	    }catch (Exception e){System.err.println(e);}
	 }// ! run() method
 
    public static void main(String[] args)throws InterruptedException {     
 
      	for (int i = 0; i < 9; i++) {
      		System.out.println("Tache "+i+" lancé");
      		Thread t = new SimulatorKuantic();
      		t.start();
      		t.join();
      	} 
      	System.out.println("Traitement terminé");
	}
 
}

a quoi sert exactement les ThreadPoolExecutor ?

Merci.

25/09/2007, 15h42
divxdede

Citation:

Envoyé par andromeda

a quoi sert exactement les ThreadPoolExecutor ?

Les Executor sont des pool de threads executant à la demande des operations (Runnable). Selon l'implémentation de l'executor celui-ci va adpoter une stratégie pour l'usage de ces threads.
25/09/2007, 15h58
adiGuba

Citation:

Envoyé par andromeda

mais en mettant le joint ca a l'air de marcher, je suis oblige de mettre des joint pour eviter des effet de bord du a la connection au serveur:

Mais en mettant un join() tu effectues chaque threads à la fin du précédent, et donc en séquentiel : bref tu n'as pas besoin de thread et une simple boucle serait amplement suffisante !

Les threads permettent de faire des traitements en parallèle...

a++
25/09/2007, 16h14
Faiche

Citation:

Envoyé par andromeda

a quoi sert exactement les ThreadPoolExecutor ?

L'idée, quand on te donne une piste sur un truc qui pourrait t'aider, c'est d'essayer au moins de regarder la doc correspondante.
26/09/2007, 01h05
andromeda

oui je regarderais, mais dans un premier temps je l'utiliserais pas , c'etait a titre d'information.

Pour l'avant post precedent:

j'avais teste avec une boucle et ca ne marchait pas, car je me conecte sur un serveur.

et dans la boucle ca plantait, ca mettait erreur socketclosed et c'etait parceque il fallait utiliser des thread pour attendre que la sequence se finisse correctement
c'est a dire , connexion, message entre client serveur, puis deconnexion, avec une boucle ca ne marchera jamais tu peux faire le test.

c'est un traitement special que je fait, c'est le seul moyen, la preuve avec la thread ca marche meme si c'est sequentiel.
26/09/2007, 08h01
divxdede

Citation:

Envoyé par andromeda

oui je regarderais, mais dans un premier temps je l'utiliserais pas , c'etait a titre d'information.

Pour l'avant post precedent:

j'avais teste avec une boucle et ca ne marchait pas, car je me conecte sur un serveur.

et dans la boucle ca plantait, ca mettait erreur socketclosed et c'etait parceque il fallait utiliser des thread pour attendre que la sequence se finisse correctement
c'est a dire , connexion, message entre client serveur, puis deconnexion, avec une boucle ca ne marchera jamais tu peux faire le test.

c'est un traitement special que je fait, c'est le seul moyen, la preuve avec la thread ca marche meme si c'est sequentiel.

Ce qu'essai de te dire adiGuba, c'est que si tu lances ta procédure sequentiellement, ne t'embettes pas a créer des threads, effectue une simple boucle (for,while) et ce sera équivalent.
26/09/2007, 13h24
andromeda

ben je l'ai deja fait mais ca ne fonctionne pas car plusieurs client a la suite des autre veulent se connecte en meme temps et sa plante, alors qu'avec une thread les connexions sont faite separement donc ca marche nikel, meme si c'est sequentiel, le fait que ce soit dans un thread il n'y a pas de conflit car il ne se connecte pas en meme temps.
26/09/2007, 13h32
adiGuba

Citation:

Envoyé par andromeda

car plusieurs client a la suite des autre veulent se connecte en meme temps et sa plante

Il n'y a pas comme une contradiction dans cette phrase ???

a++