文章首發(fā)微信公眾號(hào)，微信搜索：猿說(shuō)python

對(duì)于線(xiàn)程與線(xiàn)程之間的交互我們?cè)谇懊娴奈恼乱呀?jīng)介紹了 python 互斥鎖Lock / python事件Event , 今天繼續(xù)介紹一種線(xiàn)程交互方式 – 線(xiàn)程條件變量Condition.

一.線(xiàn)程條件變量Condition相關(guān)函數(shù)介紹

acquire() — 線(xiàn)程鎖，注意線(xiàn)程條件變量Condition中的所有相關(guān)函數(shù)使用必須在acquire() /release() 內(nèi)部操作；

release() — 釋放鎖，注意線(xiàn)程條件變量Condition中的所有相關(guān)函數(shù)使用必須在acquire() /release() 內(nèi)部操作；

wait(timeout) — 線(xiàn)程掛起(阻塞狀態(tài))，直到收到一個(gè)notify通知或者超時(shí)才會(huì)被喚醒繼續(xù)運(yùn)行（超時(shí)參數(shù)默認(rèn)不設(shè)置，可選填，類(lèi)型是浮點(diǎn)數(shù)，單位是秒）。wait()必須在已獲得Lock前提下才能調(diào)用，否則會(huì)觸發(fā)RuntimeError；

notify(n=1) — 通知其他線(xiàn)程，那些掛起的線(xiàn)程接到這個(gè)通知之后會(huì)開(kāi)始運(yùn)行，缺省參數(shù)，默認(rèn)是通知一個(gè)正等待通知的線(xiàn)程,最多則喚醒n個(gè)等待的線(xiàn)程。notify()必須在已獲得Lock前提下才能調(diào)用，否則會(huì)觸發(fā)RuntimeError，notify()不會(huì)主動(dòng)釋放Lock；

notifyAll() — 如果wait狀態(tài)線(xiàn)程比較多，notifyAll的作用就是通知所有線(xiàn)程；

二.線(xiàn)程條件變量Condition原理

在前面的文章已經(jīng)介紹過(guò)互斥鎖，主要作用是并行訪(fǎng)問(wèn)共享資源時(shí)，保護(hù)共享資源，防止出現(xiàn)臟數(shù)據(jù)。python 條件變量Condition也需要關(guān)聯(lián)互斥鎖，同時(shí)Condition自身提供了wait/notify/notifyAll方法，用于阻塞/通知其他并行線(xiàn)程，可以訪(fǎng)問(wèn)共享資源了。可以這么理解，Condition提供了一種多線(xiàn)程通信機(jī)制，假如線(xiàn)程1需要數(shù)據(jù)，那么線(xiàn)程1就阻塞等待，這時(shí)線(xiàn)程2就去制造數(shù)據(jù)，線(xiàn)程2制造好數(shù)據(jù)后，通知線(xiàn)程1可以去取數(shù)據(jù)了，然后線(xiàn)程1去獲取數(shù)據(jù)。

三.線(xiàn)程條件變量Condition使用

案例一：成語(yǔ)接龍

# !usr/bin/env python # -*- coding:utf-8 _*- """ @Author:何以解憂(yōu) @Blog(個(gè)人博客地址): shuopython.com @WeChat Official Account(微信公眾號(hào))：猿說(shuō)python @Github:www.github.com@File:python_.py @Time:2019/10/21 21:25@Motto:不積跬步無(wú)以至千里，不積小流無(wú)以成江海，程序人生的精彩需要堅(jiān)持不懈地積累！ """# 導(dǎo)入線(xiàn)程模塊 import threading# 創(chuàng)建條件變量condition con = threading.Condition()def thread_one(name):# 條件變量condition 線(xiàn)程上鎖con.acquire()print("{}:成語(yǔ)接龍準(zhǔn)備好了嗎".format(name))# 喚醒正在等待(wait)的線(xiàn)程con.notify()# 等待對(duì)方回應(yīng)消息，使用wait阻塞線(xiàn)程，等待對(duì)方通過(guò)notify喚醒本線(xiàn)程con.wait()print("{}:一干二凈".format(name))# 喚醒對(duì)方con.notify()# 等待消息答應(yīng)con.wait()print("{}:一天就知道看抖音美女，給你來(lái)個(gè)簡(jiǎn)單點(diǎn)的，來(lái)了：毛手毛腳".format(name))# 喚醒對(duì)方con.notify()# 等待消息答應(yīng)con.wait()print("{}:喲喲喲，不錯(cuò)不錯(cuò)！".format(name))# 喚醒對(duì)方con.notify()# 條件變量condition 線(xiàn)程釋放鎖con.release()def thread_two(name):# 條件變量condition 線(xiàn)程上鎖con.acquire()# wait阻塞狀態(tài)，等待其他線(xiàn)程通過(guò)notify喚醒本線(xiàn)程con.wait()print("{}:準(zhǔn)備好了~開(kāi)始吧！".format(name))# 喚醒對(duì)方con.notify()# 等待消息答應(yīng)con.wait()print("{}:凈你妹啊，沒(méi)法接...來(lái)個(gè)簡(jiǎn)單點(diǎn)的...".format(name))# 喚醒對(duì)方con.notify()# 等待消息答應(yīng)con.wait()print("{}:嘿,這個(gè)我知道：腳踏實(shí)地".format(name))# 喚醒對(duì)方con.notify()con.release()if __name__ == "__main__":# 創(chuàng)建并初始化線(xiàn)程t1 = threading.Thread(target=thread_one,args=("A"))t2 = threading.Thread(target=thread_two,args=("B"))# 啟動(dòng)線(xiàn)程 -- 注意線(xiàn)程啟動(dòng)順序，啟動(dòng)順序很重要t2.start()t1.start()# 阻塞主線(xiàn)程，等待子線(xiàn)程結(jié)束t1.join()t2.join()print("程序結(jié)束！")

輸出結(jié)果：

A:成語(yǔ)接龍準(zhǔn)備好了嗎 B:準(zhǔn)備好了~開(kāi)始吧！ A:一干二凈 B:凈你妹啊，沒(méi)法接...來(lái)個(gè)簡(jiǎn)單點(diǎn)的... A:一天就知道看抖音美女，給你來(lái)個(gè)簡(jiǎn)單點(diǎn)的，來(lái)了：毛手毛腳 B:嘿,這個(gè)我知道：腳踏實(shí)地 A:喲喲喲，不錯(cuò)不錯(cuò)！ 程序結(jié)束！

案例二：生產(chǎn)者與消費(fèi)者模式，以吃火鍋為例：一盤(pán)老肉片有10塊肉，吃完了又重新往鍋里加….

生產(chǎn)者：往鍋里加老肉片，每次加一盤(pán)(10塊)；

消費(fèi)者：吃煮熟的肉片，沒(méi)吃一片，肉片數(shù)量減一，吃完為止;

# 導(dǎo)入線(xiàn)程模塊 import threading import time# 創(chuàng)建條件變量condition con = threading.Condition() meat_num = 0def thread_consumers():# 條件變量condition 線(xiàn)程上鎖con.acquire()# 全局變量聲明關(guān)鍵字 globalglobal meat_nummeat_num = 0# 等待肉片下鍋煮熟con.wait()while True:print("我來(lái)一塊肉片...")meat_num -= 1print("剩余肉片數(shù)量：%d"%meat_num)time.sleep(0.5)if meat_num == 0:# 肉片吃光了，通知老板添加肉片print("老板，再來(lái)一份老肉片...")con.notify()# 肉片吃光了，等待肉片con.wait()# 條件變量condition 線(xiàn)程釋放鎖con.release()def thread_producer():# 條件變量condition 線(xiàn)程上鎖con.acquire()# 全局變量聲明關(guān)鍵字 globalglobal meat_num# 肉片熟了，可以開(kāi)始吃了meat_num = 10print("肉片熟了，可以開(kāi)始吃了...")con.notify()while True:# 阻塞函數(shù),等待肉片吃完的通知con.wait()meat_num = 10# 添加肉片完成，可以繼續(xù)開(kāi)吃print("添加肉片成功！當(dāng)前肉片數(shù)量：%d"%meat_num)time.sleep(1)con.notify()con.release()if __name__ == "__main__":# 創(chuàng)建并初始化線(xiàn)程t1 = threading.Thread(target=thread_producer)t2 = threading.Thread(target=thread_consumers)# 啟動(dòng)線(xiàn)程 -- 注意線(xiàn)程啟動(dòng)順序，啟動(dòng)順序很重要t2.start()t1.start()# 阻塞主線(xiàn)程，等待子線(xiàn)程結(jié)束t1.join()t2.join()print("程序結(jié)束！")

輸出結(jié)果：

肉片熟了，可以開(kāi)始吃了... 我來(lái)一塊肉片... 剩余肉片數(shù)量：9 我來(lái)一塊肉片... 剩余肉片數(shù)量：8 我來(lái)一塊肉片... 剩余肉片數(shù)量：7 我來(lái)一塊肉片... 剩余肉片數(shù)量：6 我來(lái)一塊肉片... 剩余肉片數(shù)量：5 我來(lái)一塊肉片... 剩余肉片數(shù)量：4 我來(lái)一塊肉片... 剩余肉片數(shù)量：3 我來(lái)一塊肉片... 剩余肉片數(shù)量：2 我來(lái)一塊肉片... 剩余肉片數(shù)量：1 我來(lái)一塊肉片... 剩余肉片數(shù)量：0 老板，再來(lái)一份老肉片... 添加肉片成功！當(dāng)前肉片數(shù)量：10 我來(lái)一塊肉片... 剩余肉片數(shù)量：9 我來(lái)一塊肉片... 剩余肉片數(shù)量：8 我來(lái)一塊肉片... 剩余肉片數(shù)量：7 .............

注意:

1.全局變量要聲明關(guān)鍵字 global；

2.注意線(xiàn)程的啟動(dòng)順序，這個(gè)很重要；

四.重點(diǎn)總結(jié)

注意線(xiàn)程互斥鎖Lock/線(xiàn)程事件Event/線(xiàn)程條件變量Condition三者的區(qū)別，場(chǎng)景不同，使用方式也不同，前兩者一般可以作為簡(jiǎn)單的線(xiàn)程交互，線(xiàn)程條件變量Condition可以用于比較復(fù)雜的線(xiàn)程交互！

猜你喜歡:

1.python線(xiàn)程創(chuàng)建和參數(shù)傳遞

2.python線(xiàn)程互斥鎖Lock

3.python線(xiàn)程事件Event

4.python return邏輯判斷表達(dá)式

轉(zhuǎn)載請(qǐng)注明：猿說(shuō)Python ? python條件變量Condition

想了解更多python內(nèi)容請(qǐng)直接搜索微信公眾號(hào)：猿說(shuō)python

Python教程 - 猿說(shuō)Python?www.shuopython.com

本人也還在學(xué)習(xí)python中，博客會(huì)持續(xù)更新ing，有興趣的小伙伴關(guān)注走一波，推薦瀏覽個(gè)人博客網(wǎng)站：猿說(shuō)python，文章采用樹(shù)狀分類(lèi)，結(jié)構(gòu)目錄清晰一點(diǎn)，文章內(nèi)容有問(wèn)題的話(huà)歡迎給出建議或者直接留言.

總結(jié)

以上是生活随笔為你收集整理的python 线程超时设置_python 条件变量Condition（36）的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。