你對Python 這一計算機語言感興趣嗎？你了解Python Library中Condition的具體實際應用操作的具體方法嗎？假如你對Python Library的相關操作步驟感興趣的話，你可以點擊我們的文章對其進行一個更好的了解。

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() 釋放鎖，并進入等待狀態。直到接收到 notify() 發送的消息后再次試圖獲取鎖，繼續后續代碼執行。

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

# 在釋放鎖前通知等待的線程準備起床。

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 獲得鎖，開始執行。

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 發送通知，并釋放鎖。Thread-1 5 <--- Thread1 收到消息，再次拿到鎖，開始未完成的工作。

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

wait() 實際可以分解為 "condi.release(); ... acquire()" 這兩個動作。我們可以使用 Condition 包裝已有的鎖，當然也可以用 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()   

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

【編輯推薦】

1. Python數組中實際應用的數據結構的操作方案
2. Python字符串中字符的大寫與小寫的變化
3. Python二維數組在創建過程中步驟詳解
4. 使用Python串口時應用到的模塊有哪些
5. 使用Python串口時應用到的模塊有哪些