Thread / Passage de parametres

Version imprimable

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:

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 :)

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:

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.

03/09/2013, 14h47
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 !
04/09/2013, 11h15
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:

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