使用threading.Event可以實(shí)現(xiàn)線程間相互通信,之前的Python:使用threading模塊實(shí)現(xiàn)多線程編程七[使用Condition實(shí)現(xiàn)復(fù)雜同步]我們已經(jīng)初步實(shí)現(xiàn)了線程間通信的基本功能,但是更為通用的一種做法是使用threading.Event對(duì)象。使用threading.Event可以使一個(gè)線程等待其他線程的通知,我們把這個(gè)Event傳遞到線程對(duì)象中,Event默認(rèn)內(nèi)置了一個(gè)標(biāo)志,初始值為False。一旦該線程通過(guò)wait()方法進(jìn)入等待狀態(tài),直到另一個(gè)線程調(diào)用該Event的set()方法將內(nèi)置標(biāo)志設(shè)置為T(mén)rue時(shí),該Event會(huì)通知所有等待狀態(tài)的線程恢復(fù)運(yùn)行。
'''
Created on 2012-9-9
?
@author: walfred
@module: thread.TreadTest8
'''?
?
import threading?
import time?
?
class MyThread(threading.Thread):?
??? def __init__(self, signal):?
??????? threading.Thread.__init__(self)?
??????? self.singal = signal?
?
??? def run(self):?
??????? print "I am %s,I will sleep ..."%self.name?
??????? self.singal.wait()?
??????? print "I am %s, I awake..." %self.name?
?
if __name__ == "__main__":?
??? singal = threading.Event()?
??? for t in range(0, 3):?
??????? thread = MyThread(singal)?
??????? thread.start()?
?
??? print "main thread sleep 3 seconds... "?
??? time.sleep(3)?
?
??? singal.set()
運(yùn)行效果如下:
I am Thread-1,I will sleep ...
I am Thread-2,I will sleep ...
I am Thread-3,I will sleep ...
main thread sleep 3 seconds...
I am Thread-1, I awake...I am Thread-2, I awake...
?
I am Thread-3, I awake...
更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號(hào)聯(lián)系: 360901061
您的支持是博主寫(xiě)作最大的動(dòng)力,如果您喜歡我的文章,感覺(jué)我的文章對(duì)您有幫助,請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長(zhǎng)非常感激您!手機(jī)微信長(zhǎng)按不能支付解決辦法:請(qǐng)將微信支付二維碼保存到相冊(cè),切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
