您好,登錄后才能下訂單哦!
這期內(nèi)容當(dāng)中小編將會給大家?guī)碛嘘P(guān)Python threading模塊condition的運行原理,文章內(nèi)容豐富且以專業(yè)的角度為大家分析和敘述,閱讀完這篇文章希望大家可以有所收獲。
Condition的處理流程如下:
首先acquire一個條件變量,然后判斷一些條件。
Condition的基本原理如下:
可以認(rèn)為Condition對象維護(hù)了一個鎖(Lock/RLock)和一個waiting池。線程通過acquire獲得Condition對象,當(dāng)調(diào)用wait方法時,線程會釋放Condition內(nèi)部的鎖并進(jìn)入blocked狀態(tài),同時在waiting池中記錄這個線程。當(dāng)調(diào)用notify方法時,Condition對象會從waiting池中挑選一個線程,通知其調(diào)用acquire方法嘗試取到鎖。
Condition對象的構(gòu)造函數(shù)可以接受一個Lock/RLock對象作為參數(shù),如果沒有指定,則Condition對象會在內(nèi)部自行創(chuàng)建一個RLock。
除了notify方法外,Condition對象還提供了notifyAll方法,可以通知waiting池中的所有線程嘗試acquire內(nèi)部鎖。由于上述機制,處于waiting狀態(tài)的線程只能通過notify方法喚醒,所以notifyAll的作用在于防止有的線程永遠(yuǎn)處于沉默狀態(tài)。
演示條件變量同步的經(jīng)典問題是生產(chǎn)者與消費者問題:假設(shè)有一群生產(chǎn)者(Producer)和一群消費者(Consumer)通過一個市場來交互產(chǎn)品。生產(chǎn)者的”策略“是如果市場上剩余的產(chǎn)品少于1000個,那么就生產(chǎn)100個產(chǎn)品放到市場上;而消費者的”策略“是如果市場上剩余產(chǎn)品的數(shù)量多余100個,那么就消費3個產(chǎn)品。用Condition解決生產(chǎn)者與消費者問題的代碼如下:
# -*- coding: utf-8 -*- """ Created on Wed Nov 28 17:15:29 2018 @author: 18665 """ import threading import time class Producer(threading.Thread): # 生產(chǎn)者函數(shù) def run(self): global count while True: if con.acquire(): # 當(dāng)count 小于等于1000 的時候進(jìn)行生產(chǎn) if count > 1000: con.wait() else: count = count+100 msg = self.name+' produce 100, count=' + str(count) print(msg) # 完成生成后喚醒waiting狀態(tài)的線程, # 從waiting池中挑選一個線程,通知其調(diào)用acquire方法嘗試取到鎖 con.notify() con.release() time.sleep(1) class Consumer(threading.Thread): # 消費者函數(shù) def run(self): global count while True: # 當(dāng)count 大于等于100的時候進(jìn)行消費 if con.acquire(): if count < 100: con.wait() else: count = count-5 msg = self.name+' consume 5, count='+str(count) print(msg) con.notify() # 完成生成后喚醒waiting狀態(tài)的線程, # 從waiting池中挑選一個線程,通知其調(diào)用acquire方法嘗試取到鎖 con.release() time.sleep(1) count = 500 con = threading.Condition() def test(): for i in range(2): p = Producer() p.start() for i in range(5): c = Consumer() c.start() if __name__ == '__main__': test()
上述就是小編為大家分享的Python threading模塊condition的運行原理了,如果剛好有類似的疑惑,不妨參照上述分析進(jìn)行理解。如果想知道更多相關(guān)知識,歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。