Discussion :

[MiJack]

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 :

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

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]

[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{}.

[herve91]

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 :

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
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) {
  }
}

[adiGuba]

Salut,


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

Code :

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

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++

[MiJack]

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

Code :

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

thr.start();

Erreur ->

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 ?

[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.

[MiJack]

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 !