Python Library中Condition的具体操作方案

Python Library中Condition的具体操作方案

你对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() 的线程必须事先获得锁，否则会抛出异常。