Discussion :

[panda31]

Bonjour à tous,

J'ai un souci de conception et/ou de langage sur les threads.
Pour situer le topo, je fais un lanceur de tâches avec une GUI en Tkinter. Chaque tâche est lancée dans un thread.
Le problème est que je veux que le thread n+1 ne se lance pas avant la fin d'exécution du thread n.

J'ai lu quelques doc et la doc officielle du module Queue qui semble la clé du problème mais je pige pas trop comment s'imbrique le tout.

Pouvez-vous m'aider svp ?

Merci d'avance !

[Antoine_935]

Salut

C'est un peu trop flou pour pouvoir t'aider efficacement.
Peux-tu préparer à l'avance tous les threads avant de lancer le premier ou vas tu en ajouter au fur et à mesure ?
Si tu en rajoutes, quel thread les rajoute ? le main, ou un des threads lancés ?

De ce que je vois, une solution serait d'avoir un thread qui se charge de lancer les autres à tour de rôle, à l'aide de wait et autres.
Ces threads seraients stockés dans une simple liste.
Tu peux utiliser une queue à la place si tu as besoin d'empêcher les accès concurrents à cette liste.

Ca ressemblerait un peu à ceci (non testé):

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
from threading import Thread
from queue import Queue
 
class ThreadManager(Thread):
    def __init__(self):
        Thread.__init__(self)
        self.__queue = Queue(0)
 
    def enqueueThread(self, thread):
        self.__queue.put(thread)
 
    def run(self):
        while 1:
            nextThread = self.__queue.get(True)
            nextThread.start()
            nextThread.wait()
 
# Et dans ton code sensé lancer les tâches
threadManager = ThreadManager()
threadManager.start()
 
# Ajout d'une tâche
threadManager.enqueueThread(myThread)

Je pense qu'avec quelques détails de plus on pourrait sans doute te donner une meilleure réponse

[ju_bicycle]

Sinon tu as la méthode .join() dans threading qui permet d'attendre la fin de l'execution du thread associé pour continuer

Par exemlpe tu a un thread appelé "MyToto" qui tourne

si tu utilise MyToto.join(),ton prog restera bloqué à cette ligne la jusqu'à la fin de l'éxécution du ton thread

[panda31]

Alors, pour préciser davantage :
- Je crée mes thread et je les stocke dans une liste
- Je veux ensuite les lancer les uns après les autres en précisant que le 2nd ne démarre qu'après la fin du premier, etc...

Est-ce plus clair ?

[ju_bicycle]

je confirme...méthode join()

Code :

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

1
2
3
4
5
6
 
liste = [thread1,thread2,...,threadn]
 
for i in len(liste):
      liste[i].start()
      liste[i].join()

[panda31]

Si tu fais cela, tu prends le risques de freezer l'ihm non ?