Python线程专题7:条件变量

上一篇文章： Python线程专题6:事件
下一篇文章： Python线程专题8:使用锁的注意事项

条件变量时构建在另外一个锁上的同步原语，当须要线程关注特定的状态变化或事件发生时将使用这个锁。典型的用法是生产者与消费者问题，其中一个线程生产的数据提供给另一个线程使用。

语法：

c=Condition(lock)
穿件新的条件变量。lock时可选的Lock或RLock的实例。若是未提供lock参数，就会建立新的RLock实例供条件变量使用。

经常使用方法：

c.acquire(*args):获取底层锁。此方法将调用底层锁上对应的acquire(*args)方法。

c.release()：释放底层锁。此方法将调用底层锁上对应的release()方法

c.wait(timeout)：等待直到获取通知或出现超时为止。此方法在调用线程已经获取锁以后调用。
调用时，将释放底层锁，并且线程将进入睡眠状态，直到另外一个线程在条件变量上执行notify()或notify_all()方法将其唤醒为止。
在线程被唤醒后，线程讲从新获取锁，方法也会返回。timeout是浮点数，单位为秒。
若是超时，线程将被唤醒，从新获取锁，而控制将被返回。

c.notify(n)：唤醒一个或多个等待此条件变量的线程。此方法只会在调用线程已经获取锁以后调用，
并且若是没有正在等待的线程，它就什么也不作。
n指定要唤醒的线程数量，默认为1.被唤醒的线程在它们从新获取锁以前不会从wait()调用返回。

c.notify_all()：唤醒全部等待此条件的线程。

实例模版：使用条件变量

#条件变量实例
from threading import Condition

c=Condition()
def producer():
    while True:
        c.acquire()
        #生产东西
        ...
        c.notify()
        c.release()

def consumer():
    while True:
        c.acquire()
        while 没有可用的东西:
            c.wait()#等待出现
        c.release()
        #使用生产的东西
        ...

注意：若是存在多个线程等待同一个条件，notify()操做会唤醒他们中的一个或多个（这种行为取决于底层的操做系统）。所以，始终有这样的可能：某个线程被唤醒后，缺发现它等待的条件不存在了，这解释了为何在consumer函数中使用while循环，若是线程醒来，可是生成的项已经消失，它就会回去等待下一个信号。