python多線程編程(7):線程間通信


很多時候,線程之間會有互相通信的需要。常見的情形是次要線程為主要線程執行特定的任務,在執行過程中需要不斷報告執行的進度情況。前面的條件變量同步已經涉及到了線程間的通信(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()




免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM