Discussion :

[goomie]

bonjour je cherche synchroniser trois thread le deuxieme doit se lancer apres le premier et le troisieme apres le deuxieme voici mon code

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
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
from random import random
from time import mktime,localtime,sleep
from threading import Thread,Timer,Event
from sys import exit,argv       
class Loto:
 
    def __init__(self,intloto,lister,intentier,listerentier):
        self.integer=intloto
        self.liste=lister
        self.int=intentier
        self.liste_entier=listerentier
        self.masquer=0
 
    def rdm(self):
 
        for t in range(0,self.integer):
 
            self.liste.insert(0,random())
        print self.liste
        sleep(2)
        self.masquer=1
 
    def wait(self):
        print localtime()
        a=Timer(1,self.rdm,[],{})
        a.start()
 
 
    def afterrdm(self):
        for t in self.liste_entier:
            self.int=self.int+t
 
        print self.int
 
    def waitafter(self):
 
        a=Timer(2,self.afterrdm,[],{})
        a.start()
        print localtime()
 
        quit()
 
    def purge(self):
 
        print self.liste
        for t in self.liste:
               self.liste_entier.insert(0,round(t))
 
 
        print self.liste_entier
 
a=Loto(47,[],0,[])
event=Event()
q0=Thread(None,a.wait,None,(),None)
q0.start()
event.set()
q0.join(2)
q3=Thread(None,a.purge,None,(),None)
q3.start()
q3.join(2)
q1=Thread(None,a.waitafter,None,(),None);
 
q1.start()
q1.join()

toute propositiion est la bien venue en attendant un post svp,je vais continuer a chercher de la doc ou des exemple
merci et bon courage a tous a++

[goomie]

mais ca ne marche pas mes ressource critique ets toujours instancier comme au debut j ai une question est ce que je peux bloquer un thread qui appelle une methode de classe si j instancie un Lock dans ma classe
je ne sais pas si j ai etait clair,je reste a votre dispo pour toute precision

[tyrtamos]

Bonjour,

Je ne me suis pas lancé dans l'interprétation de ton code, mais si tu veux que les 3 threads, une fois lancés, interviennent dans un ordre particulier, voilà comment je ferais:

- créer une variable "statut" (éventuellement globale ou équivalent) consultable et modifiable par tous les threads, et initialisée à 1.

- créer un verrou vstatut" (Lock) pour l'utilisation de cette variable par les threads

- chaque thread est codé de la façon suivante:

1- pour le 1er thread:

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
 
# avant le début de l'action:
while True:
    vstatut.acquire()
    if statut==1:
        vstatut.release()
        break
    vstatut.release()
    # selon l'application, tu peux mettre une tempo ici. Ex: time.sleep(0.1)
 
# action
...
...
 
# et à la fin de l'action:
vstatut.acquire()
statut=2
vstatut.release()

2- pour le 2ème: idem à part que la valeur cherchée est statut==2 et que celui-ci passe à 3 à la fin

3- pour le 3ème: idem à part que la valeur cherchée est statut==3 et que celui-ci passe à ??? à la fin selon la suite que tu souhaites donner. Si ça repasse à 1, le cycle recommence si les threads ont été maintenus en vie (dans une sur-boucle while par exemple).

En faisant comme cela, tu peux lancer les threads dans n'importe quel ordre, il n'agiront que dans l'ordre précisé par les valeurs successives de la variable "statut".

Tyrtamos

[dividee]

Bonjour,

Juste une petite amélioration: on pourrait utiliser une Condition (classe du module threading) au lieux d'un Lock, afin d'éviter une attente active.
Avertissement: Je n'ai pas testé ce qui suit.
Si la condition s'appelle cond, le code dans le premier thread ressemblerait à ceci:

Code :

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

1
2
3
4
5
6
7
8
9
cond.acquire()
while statut <> 1:
    cond.wait()        # attend d'être notifié d'un changement de statut
 
# action thread 1
 
statut = 2
cond.notifyAll()       # signale que la valeur de statut a changé
cond.release()

Idem dans les 2 autres threads, en changeant la valeur de statut.

En regardant le code du premier post, je me rends compte qu'il y a d'autres threads que ces trois là, créés par Timer. Il faudrait que la statut et la notification soient effectués après l'expiration de ces timers, mais si tu ne veux pas modifier le code appelé par ces Timers, une solution simple serait de faire un join sur le Timer juste après le start. Mais je ne vois pas trop pourquoi introduire tant de complexité artificiellement...

[goomie]

j ai effecttivement utiliser un lock mais ca marche aussi bien avec un semaphore ou une condition en fait j ai aussi lever le timer qui faisais suer
et le lock je l ai actionner juste avant l utilisation du thread et je le relache juste appres et pareil pour les autres thread
merci a vous deux pour vos lumiere