Discussion :

[Tlams]

Bonjour !

Je cherche à faire passer un paramètre entre deux threads.

Pour l'exemple type NON fonctionnel mais qui représente bien ce que je cherche à faire:

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
 
#!/usr/bin/python
# -*- coding: utf-8 -*- 
 
import threading
import time
 
class thread_1(threading.Thread):  
    def __init__(self, nom=''):
        threading.Thread.__init__(self)
        self.nom = nom
        self.Terminated = False       
 
    def run(self):
        param = "HEY"
        while True:
            time.sleep(2)
            print param
 
    def stop(self):
        self.Terminated = True
 
 
class thread_2(threading.Thread):    
    def __init__(self, nom=''):
        threading.Thread.__init__(self)
        self.nom = nom
        self.Terminated = False
 
    def run(self):
        time.sleep(5)
        param = "changement !"
 
    def stop(self):
        self.Terminated = True
 
 
print "Lancement des threads...",
a = thread_1('Threadname_1')
a.start()
 
b = thread_2('Threadname_2')
b.start()
print "[OK]"

Vous l'aurez sans doute remarqué, j’essaye de changer le paramètre "param" qui est affiché par le Thread_1 en modifiant sa valeur dans le Thread_2 au bout de 5secondes.

Après avoir un peu googler , j'ai vu des pistes en utilisant "queue"... Mais j'ai pas vraiment compris.

Donc si quelqu'un saurait !

Merci

[tyrtamos]

Bonjour,

Sans utiliser queue, on peut faire, en plaçant "param" comme variable globale, et en permettant à chacun des threads de modifier sa valeur, mais à condition d'utiliser un verrou, pour empêcher les tentatives d'accès simultannés.

Voilà un petit exemple sur la base de ton 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
import threading
import time
 
class thread_1(threading.Thread):
    def __init__(self, nom=''):
        threading.Thread.__init__(self)
        self.nom = nom
        self.encore = True
 
    def run(self):
        global verrou
        while self.encore:
            time.sleep(0.5)
 
            verrou.acquire()
            param = self.nom
            print param
            verrou.release()
 
    def stop(self):
        self.encore = False
 
 
class thread_2(threading.Thread):
 
    def __init__(self, nom=''):
        threading.Thread.__init__(self)
        self.nom = nom
        self.encore = True
 
    def run(self):
        global verrou
        while self.encore:
            time.sleep(0.5)
 
            verrou.acquire()
            param = self.nom
            print param
            verrou.release()
 
    def stop(self):
        self.encore = False
 
verrou = threading.Lock()
 
param = None
 
print "Lancement des threads..."
 
a = thread_1('Threadname_1')
a.start()
 
b = thread_2('Threadname_2')
b.start()
 
time.sleep(10)
 
a.stop()
b.stop()
while a.isAlive() or b.isAlive():
    time.sleep(0.1)
 
print "Fin"

Comme on peut le voir dans les sorties, il n'est pas garanti que les threads agissent alternativement sur param. Si on le voulait, on pourrait ajouter une variable supplémentaire pour que chaque thread attende que l'autre ait agi pour agir lui-même.

[Tlams]

Bon, je n'ai pas encore pigé tous ce que tu as modifié, mais effectivement en définissant la même variable globale dans chaque thread, sa permet de passer des paramètres.

Merci pour ton aide !

[TekP@f]

Salut,

C'est quand même assez moche d'utiliser des variables globales pour ça.
Tu peux passer des paramètres à un thread de cette façon.

Code :

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

1
2
3
4
objThread = threading.Thread(target=ma_fonction, args=[value1,value2])
 
def ma_fonction(param1, param2):
    pass