你對(duì)Python 這一計(jì)算機(jī)語言感興趣嗎？你了解Python Library中Condition的具體實(shí)際應(yīng)用操作的具體方法嗎？假如你對(duì)Python Library的相關(guān)操作步驟感興趣的話，你可以點(diǎn)擊我們的文章對(duì)其進(jìn)行一個(gè)更好的了解。

Condition 算是 Lock 和 Event 的雜交版本，除了作為 Lock 的基本功能外，還提供了 wait() 和 notify() 作為線程間 "消息通知"。

from threading import *  
from time import *  
condi = Condition()  
def t1():  
condi.acquire()  
try:  
for i in range(10):  
print currentThread().name, i  
sleep(1)  
if (i == 4): condi.wait()    

# wait() 釋放鎖，并進(jìn)入等待狀態(tài)。直到接收到 notify() 發(fā)送的消息后再次試圖獲取鎖，繼續(xù)后續(xù)代碼執(zhí)行。

finally:  
condi.release()  
def t2():  
condi.acquire()  
try:  
for i in range(10):  
print currentThread().name, i  
sleep(1)  
finally:  
condi.notify()   

# 在釋放鎖前通知等待的線程準(zhǔn)備起床。

condi.release()  
Thread(target=t1).start()  
Thread(target=t2).start()  

輸出:

$ ./main.py  
Thread-1 0  
Thread-1 1  
Thread-1 2  
Thread-1 3   

Thread-1 4 <--- Thread1 釋放鎖，開始等待。Thread-2 0 <--- Thread2 獲得鎖，開始執(zhí)行。

Thread-2 1  
Thread-2 2  
Thread-2 3  
Thread-2 4  
Thread-2 5  
Thread-2 6  
Thread-2 7  
Thread-2 8  

Thread-2 9 <--- Thread2 發(fā)送通知，并釋放鎖。Thread-1 5 <--- Thread1 收到消息，再次拿到鎖，開始未完成的工作。

Thread-1 6  
Thread-1 7  
Thread-1 8  
Thread-1 9 

wait() 實(shí)際可以分解為 "condi.release(); ... acquire()" 這兩個(gè)動(dòng)作。我們可以使用 Condition 包裝已有的鎖，當(dāng)然也可以用 with/as 來改善我們的代碼。

lock = RLock()  
condi = Condition(lock)  
def t1():  
with condi:  
for i in range(10):  
print currentThread().name, i  
sleep(1)  
if (i == 4): condi.wait()  
def t2():  
with lock:  
for i in range(10):  
print currentThread().name, i  
sleep(1)  
condi.notify()  
Thread(target=t1).start()  
Thread(target=t2).start()   

注意調(diào)用 notify() 和 notifyall() 的線程必須事先獲得鎖，否則會(huì)拋出異常。

【編輯推薦】

1. Python數(shù)組中實(shí)際應(yīng)用的數(shù)據(jù)結(jié)構(gòu)的操作方案
2. Python字符串中字符的大寫與小寫的變化
3. Python二維數(shù)組在創(chuàng)建過程中步驟詳解
4. 使用Python串口時(shí)應(yīng)用到的模塊有哪些
5. 使用Python串口時(shí)應(yīng)用到的模塊有哪些