Discussion :

[stujava]

Salut à tous,

Je cherche un exemple clair et simple pour la gestion des Thread dans un ThreadGroup

En fait je dois exécuter 10 theard en parallèle et je pensais utiliser un ThreadGroup mais je ne comprend pas le fonctionnement.

J'ai une classe qui étend Thread appelé T.
Ensuite je l'ajoute comme ceci

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
 
ThreadGroup tg = new ThreadGroup("TGTest");
Thread t1 = new Thread(tg,new T(),"thread1");
Thread t2 = new Thread(tg,new T(),"thread2");
....

Si je fais ceci, comment exécuter mes thread ?

Et une autre question, dans mes thread je fais évoluer un compteur, comment puis en récupérer la valeur une fois le thread terminé ?

D'avance merci pour votre aide.
stujava

[tchize_]

1) en appelant start() sur le thread
2) en créant un accesseur pour ce champ et en l'appelant
tonT.getTonChamp().

Pour attendre qu'un thread aie fini, il faut appeler sa méthode join().

[stujava]

Merci pour les infos, mais en fait je dois récupérer une valeur dans chacun des trends mais uniquement quand ceux-ci on fini leur travail, hors dans ma classe appelante j'ai mis le code thread.join(); cependant il passe directement au code suivant qui va récupérer le contenu de la variable mais celles-ci sont à 0 et donc je ne récupère rien.

Que dois-je faire ?

Merci pour votre aide

[tchize_]

join() ne retourne que quand le thrad à fini. Si la variable n'est pas initialisée, c'est que tu n'a pas fait le join sur ce thread.

[stujava]

Dans ma classe appelante et instanciant les thread je fais ceci :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
 
int total = 0;
Thread tg = new Thread[threadGroup.activeAccount()];
 
for(int i=0; i < tg.length;i+){
((Thread) tg[i]).join();
}
for(int i=0; i < tg.length;i++){
total += ((Thread) tg[i]).getTotal();
}
 System.out.println("Total =  " +total);

Le fait est que le sysout montre 0 et pas le total des lignes traitées par thread.
Où ai-je commis l'erreur ?

Merci pour l'aide

[tchize_]

Déjà, ce code ne compile pas:
tg devrait être un tableau
le tableau ne contient que des nulls
Thread n'a pas de méthode getTotal.

Au delà de ça, en supposant qu'il ne s'agit pas de votre code réel, je dirait que getTotal renvoie n'importe quoi.

[Robin56]

tg devrait être un tableau

Première réaction : Oh tu ne parles pas bien aux visiteurs de Developpez.net
Deuxième réaction : Ah oui, en effet, il y a une variable se nommant "tg"

[stujava]

Bonjour,

Et bien il ne fait pas bon poser des questions sur ce forum sans avoir des attaques plus que déplacées.

La personne qui se cache derrière le pseudo tchize_ a sans doute oublier qu'elle aussi a débuté un jour et sans doute se croit tellement parfaite qu'elle ne semble même plus donner le droit à l'erreur aux autres.

Bref voici donc les explications pour le code ci dessous :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
 
 
int total = 0;
Thread[] tg = new Thread[threadGroup.activeAccount()];
 
for(int i=0; i < tg.length;i+){
((Thread) tg[i]).join();
}
for(int i=0; i < tg.length;i++){
total += ((Thread) tg[i]).getTotal();
}
 System.out.println("Total =  " +total);

D'une part je ne donne pas mon code réel, ensuite, la variable tg est juste là pour indiqué que je crée un tableau de thread, enfin la méthode getTotal() et une méthode de mon thread permettant de récupérer le contenu d'une variable modifiée lors de l'exécution du thread.

Donc , mon souhait est que lorsque les threads sont terminés, j'aimerai récupérer le contenu d'une valeur pour chacun des threads, le souci est qu'avec le code ci-dessus, il récupère les valeurs avant même que les threads soient terminés, je conçois avoir commis une erreur et donc j'aimerai de l'aide pour comprendre et corriger. Merci

Est-ce suffisamment clair ou souhaitez-vous un complément d'informations ?

D'avance merci pour votre aide et désolé si je suis un débutant qui commet des erreurs.

Stujava

[tchize_]

Comme je l'ai dit, ça ne peux pas être votre code car ca code ne peux pas compiler (la classe Thread n'a pas de méthode getTotal). De plus vous ne créez pas de Threads, vous n'initialisez pas le tableau et vous ne démarrez pas de thread. Il faudrait avoir le code réel que vous utilisez avant de pouvoir vous dire ou est le problème. On est pas devin.

[stujava]

Merci de lire clairement et avec attention le dernier message laissé ci-dessus.

[stujava]

Voici le code complet mais je doute que cela puisse mieux vous servir.

J'ai initialement une classe TestThread qui étend Thread et qui a une méthode GetTotal().

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
/* Map contenant les données utile pour les threads */
 
Map globalListData = new HashMap<String,ArrayList<String>>();
TestThread  dbt = null;
ThreadGroup threadGroup = new ThreadGroup("ThreadGRP");
Thread t = null;
 
for(Iterator iter = globalListData.keyset().iterator; iter.hasNext();){
String key = (String) iter.next();
dbt = new TestThread(key, (List) globalListData.get(key), "Thread id :" + key);
t = new Thread(threadGroup, dbt, "T" + key);
t.start();
}
 
Thread[] tg = new Thread[threadGroup.activeAccount()];
 
for(int i=0; i < tg.length;i+){
((Thread) tg[i]).join();
}
for(int i=0; i < tg.length;i++){
total += ((Thread) tg[i]).getTotal();
}
 System.out.println("Total =  " +total);

Voilà le code au complet, cela vous aide-t-il plus ?

Cordialement.

[tchize_]

oui, on peux y voir que vous n'initialisez pas votre tableau de threads. Il est vide.

Le code correct devrait ressembler à ça:

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
 
List<Thread> threads = new ArrayList<Thread>();
List<TestThread> testThreads = new ArrayList<TestThread>();
for(Iterator iter = globalListData.keyset().iterator; iter.hasNext();){
  String key = (String) iter.next();
  dbt = new TestThread(key, (List) globalListData.get(key), "Thread id :" + key);
  t = new Thread(threadGroup, dbt, "T" + key);
  t.start();
  threads.add(t);
  testThreads.add(dbt);
}
for(Thread thread : threads){
    thread.join();
}
for(TestThread testThread : testThreads){
  total += testThread.getTotal();
}

[stujava]

Merci pour les précisions, cela donne le résultat attendu.

Un tout grand merci pour la patience et les infos.
Cordialement.