[Threads] Actions continues avec des threads

Version imprimable

10/10/2005, 16h09
MiJack

[Threads] Actions continues avec des threads
Hello,

Données du problèmes :
-> je dois contrôler différents objets de manière continue au moyen de threads (programme tourne en boucle)
-> je ne peux lancer qu'un nombre limité de threads
-> les threads peuvent être lancés depuis les objets ou l'objet peut être un paramètre du thread, c'est à choix

Exemple :
-> j'ai 10 objets OBJ stockés dans un tableau TAB
-> je ne peux avoir que 5 threads en même temps

Ce que je pensais faire :
Code:

1 2 3 4 5 6 7 while (true) //pour tourner indéfiniment { for (int i = 0; i < 10; i++) { threads thr = new threads(TAB[i]); } }
Le problème est que je ne sais pas vraiment comment empêcher d'avoir plus de 5 threads à la fois. Il faudrait que lorsque le nombre maximal de threads a été atteind, le programme attend qu'un thread se termine pour lancer le suivant.

Comment puis-je faire ça ?[/quote]
10/10/2005, 16h23
xavlours

Il te faut utiliser un sémaphore entier. Une rapide recherche n'a pas donné grand chose, je ne sais pas si ca existe en Java, mais tu peux le coder à partir des synchronisations synchronized{}.

Et bien tu gères un tableau des threads que tu as lancé, et tu vérifies s'ils ont terminé leur exécution :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
Thread[] threads = new Thread[5];
 
index = 0;
while (true) {
  for (int i = 0; i < threads.length; i++) {
    if (threads[i] == null || !threads[i].isAlive()) {
      thread = new Thread(TAB[index]);
      index = (index + 1) % 10;
 
      threads[i] = thread;
      thread.start();
    }
  }
 
  // pour éviter de consommer trop de temps CPU
  try {
    Thread.sleep(50);
  } catch (InterruptedException ex) {
  }
}

10/10/2005, 16h44
adiGuba
Salut,

Si tu utilises java 5.0 tu peux utiliser la nouvelle API de concurrence et les executeurs de tâches :
Code:

1 2 3 4 ExecutorService executor = Executors.newFixedThreadPool(5); for (int i = 0; i < 10; i++) { executor.execute(new threads(TAB[i])); }
Sinon il va falloir gérer cela toi même, eventuellement en gérant des listeners qui avertiront ta classe principale lorsqu'un thread est terminé...

a++
10/10/2005, 17h04
MiJack

Merci, j'ai essayé le code d'hervé91, mais j'ai une erreur sur la ligne

Code:

thr.start();

Erreur ->

Citation:

java.lang.IllegalThreadStateException
at java.lang.Thread.start(Native Method)
at intrusion.testIntrusion.main(testIntrusion.java:86)

Et je n'ai qu'un seul thread qui démarre. Faut-il définir un état particulier avant de lancer les threads ? 8O
10/10/2005, 17h17
herve91

Peux-tu poster le code complet de la boucle ?
L'exception signifie que tu appelles deux fois la méthode start() sur une même instance de Thread.
10/10/2005, 17h32
MiJack

Citation:

Envoyé par herve91

L'exception signifie que tu appelles deux fois la méthode start() sur une même instance de Thread.

Bien vu, grâce à cette information j'ai trouvé où se trouvait l'erreur (en fait j'utilisais la méthode start() dans le constructeur du thread).

Merci encore pour le code !