新聞中心
為了更有效地同步對任何資源的訪問,我們可以將條件與任務(wù)相關(guān)聯(lián),讓任何線程等待,直到滿足某個條件,或者通知其他線程該條件正在滿足,以便它們可以解除對自身的阻止。

網(wǎng)站建設(shè)哪家好,找創(chuàng)新互聯(lián)建站!專注于網(wǎng)頁設(shè)計、網(wǎng)站建設(shè)、微信開發(fā)、微信小程序開發(fā)、集團(tuán)企業(yè)網(wǎng)站建設(shè)等服務(wù)項目。為回饋新老客戶創(chuàng)新互聯(lián)還提供了瀾滄免費(fèi)建站歡迎大家使用!
讓我們舉一個簡單的例子來理解這一點(diǎn)。在生產(chǎn)者消費(fèi)者問題中,如果有一個生產(chǎn)者生產(chǎn)某一物品,一個消費(fèi)者消費(fèi)該物品,那么在生產(chǎn)者生產(chǎn)該物品之前,消費(fèi)者不能消費(fèi)該物品。因此,消費(fèi)者要等到產(chǎn)品生產(chǎn)出來。生產(chǎn)者有責(zé)任告知消費(fèi)者,一旦產(chǎn)品成功生產(chǎn),就可以消費(fèi)。
如果有多個消費(fèi)者消費(fèi)生產(chǎn)者生產(chǎn)的產(chǎn)品,那么生產(chǎn)者必須通知所有消費(fèi)者生產(chǎn)的新產(chǎn)品。
這是 python 多線程中條件對象的完美用例。
條件對象:wait()、notify()和notifyAll()
現(xiàn)在我們知道了 python 多線程中條件對象的用途,讓我們看看它的語法:
condition = threading.Condition([lock])條件對象接受一個可選的鎖對象作為參數(shù)。如果我們不提供任何東西,那么它會創(chuàng)建一個默認(rèn)鎖。
條件對象有acquire()和release()方法,調(diào)用關(guān)聯(lián)鎖的相應(yīng)方法。還有wait()方法、notify()方法、notifyAll()方法。這三個只能在調(diào)用線程獲得鎖后調(diào)用。
條件類方法
以下是條件類方法:
acquire(*args)方法
此方法用于獲取鎖。該方法對條件對象中存在的基礎(chǔ)鎖調(diào)用相應(yīng)的acquire()方法;返回值是該方法返回的任何值。
release()方法
此方法用于釋放鎖。該方法對條件對象中存在的基礎(chǔ)鎖調(diào)用相應(yīng)的release()方法。
wait([timeout])方法
此方法用于阻塞線程,并使其等待,直到其他線程通過在同一條件對象上調(diào)用notify()或notifyAll()方法通知它,或者直到超時發(fā)生。
只有當(dāng)調(diào)用線程獲得鎖時,才能調(diào)用這個函數(shù)。
當(dāng)被調(diào)用時,這個方法釋放鎖,然后阻塞線程,直到被其他線程對相同條件變量的notify()或notifyAll()調(diào)用喚醒,或者直到超時發(fā)生。
如果由于notify()或notifyAll()方法而被釋放,該方法返回True,否則如果超時,該方法將返回False布爾值。
notify()方法
它會喚醒任何等待相應(yīng)條件的線程。只有當(dāng)調(diào)用線程獲得鎖時,才能調(diào)用這個函數(shù)。此外,調(diào)用此方法只會喚醒一個等待的線程。
notifyAll()方法
它會喚醒所有等待這個條件的線程。這個方法的行為類似于notify()方法,但是喚醒了所有等待的線程,而不是一個。
是時候舉個例子了!
在下面的代碼示例中,我們實現(xiàn)了一個簡單的生產(chǎn)者-消費(fèi)者解決方案,生產(chǎn)者生產(chǎn)一個項目,并將其添加到消費(fèi)者消費(fèi)這些項目的列表中。
上面的代碼示例中有幾個重要的要點(diǎn):
- 我們創(chuàng)建了一個類
SomeItem,它有一個list,作為生產(chǎn)者和消費(fèi)者線程之間的共享資源。 - 生產(chǎn)者線程正在隨機(jī)生成一些列表項,并將其添加到列表中。
- 消費(fèi)線程嘗試消費(fèi)物品,如果沒有找到物品,則開始等待。如果生產(chǎn)者在超時前向消費(fèi)者發(fā)送關(guān)于項目創(chuàng)建的通知,那么消費(fèi)者消費(fèi)該項目,否則由于超時而退出。
這是一個非常簡單的例子,涵蓋了條件對象的所有用例。嘗試用 2 個使用者線程和一個生產(chǎn)者線程運(yùn)行上面的程序。
文章標(biāo)題:Python中的條件對象——線程同步
當(dāng)前網(wǎng)址:http://m.5511xx.com/article/dpsoocg.html


咨詢
建站咨詢
