我们可以在线程类外部定义变量,并在类的方法内部全局声明它。
请参见下面的简单示例,它交替打印AB。两个变量flag
和val
在两个线程Thread_A
和之间共享Thread_B
。Thread_A
打印val=20
,然后设置val
为30。Thread_B
打印val=30
,因为val
已在中进行了修改Thread_A
。Thread_B
然后设置val
为20,再次用于中Thread_A
。这表明变量val
在两个线程之间共享。同样flag
,两个线程之间也共享变量。
import threading
import time
c = threading.Condition()
flag = 0 #shared between Thread_A and Thread_B
val = 20
class Thread_A(threading.Thread):
def __init__(self, name):
threading.Thread.__init__(self)
self.name = name
def run(self):
global flag
global val #made global here
while True:
c.acquire()
if flag == 0:
print "A: val=" + str(val)
time.sleep(0.1)
flag = 1
val = 30
c.notify_all()
else:
c.wait()
c.release()
class Thread_B(threading.Thread):
def __init__(self, name):
threading.Thread.__init__(self)
self.name = name
def run(self):
global flag
global val #made global here
while True:
c.acquire()
if flag == 1:
print "B: val=" + str(val)
time.sleep(0.5)
flag = 0
val = 20
c.notify_all()
else:
c.wait()
c.release()
a = Thread_A("myThread_name_A")
b = Thread_B("myThread_name_B")
b.start()
a.start()
a.join()
b.join()
输出看起来像
A: val=20
B: val=30
A: val=20
B: val=30
A: val=20
B: val=30
A: val=20
B: val=30