Gestion des Thread dans un ThreadGroup

Version imprimable

21/12/2011, 12h48
stujava

Gestion des Thread dans un ThreadGroup
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:

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
21/12/2011, 18h29
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().
22/12/2011, 15h08
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
22/12/2011, 15h48
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.

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

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

22/12/2011, 19h39
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.
22/12/2011, 20h30
Robin56

Citation:

Envoyé par tchize_

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" :aie:

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:

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

23/12/2011, 09h02
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.
23/12/2011, 09h19
stujava

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

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:

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.

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

Le code correct devrait ressembler à ça:

Code:

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();
}

23/12/2011, 10h53
stujava

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

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