Python執行緒下條件變數的用法

這篇文章帶給大家的內容是關於Python線程中條件變數的用法，有一定的參考價值，有需要的朋友可以參考一下，希望對你有幫助。

條件變數時建構在另一個鎖上的同步原語，當需要執行緒關注特定的狀態變化或事件發生時將使用這個鎖。典型的用法是生產者與消費者問題，其中一個執行緒生產的資料提供給另外一個執行緒使用。

語法：

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循環，如果執行緒醒來，但是生成的項已經消失，它就會回去等下一個訊號。

相關推薦：

關於條件變數、執行緒的10篇文章推薦

淺析Python多執行緒下的變數問題

以上是Python執行緒下條件變數的用法的詳細內容。更多資訊請關注PHP中文網其他相關文章！