很多時候,線程之間會有互相通信的需要。常見的情形是次要線程為主要線程執行特定的任務,在執行過程中需要不斷報告執行的進度情況。前面的條件變量同步已經涉及到了線程間的通信(threading.Condition的notify方法)。更通用的方式是使用threading.Event對象。
threading.Event可以使一個線程等待其他線程的通知。其內置了一個標志,初始值為False。線程通過wait()方法進入等待狀態,直到另一個線程調用set()方法將內置標志設置為True時,Event通知所有等待狀態的線程恢復運行。還可以通過isSet()方法查詢Envent對象內置狀態的當前值。
舉例如下:
import threading
import random
import time
class MyThread(threading.Thread):
def __init__(self,threadName,event):
threading.Thread.__init__(self,name=threadName)
self.threadEvent = event
def run(self):
print "%s is ready" % self.name
self.threadEvent.wait()
print "%s run!" % self.name
sinal = threading.Event()
for i in range(10):
t = MyThread(str(i),sinal)
t.start()
sinal.set()