不廢話，直接上四種模式，為方便大家復(fù)制，直接貼出代碼

1、條件變量(Condition)方式，最復(fù)雜的一種

# 條件變量(Condition)：鎖功能加入等待和喚醒功能，默認(rèn)RLock# 兩個(gè)線程用一個(gè) cond 鎖，手動(dòng)喚醒和等待import timefrom threading import Threadfrom threading import Conditioncond = Condition() # 兩個(gè)線程共享一個(gè)鎖num = 0def producer(): # 生產(chǎn)者線程 global num with cond: while True: num += 1 print('生產(chǎn)1個(gè)，總數(shù)：{}'.format(num)) if num == 3: print('已達(dá)到3個(gè)，不再生產(chǎn)') time.sleep(3) cond.notify() # 循環(huán) 3 次，喚醒消費(fèi)者線程 cond.wait() # 釋放鎖，掛起生產(chǎn)者線程def customer(): # 消費(fèi)者線程 global num with cond: while True: num -= 1 print('消費(fèi)了1個(gè)，剩余：{}'.format(num)) if num == 0: print('已消費(fèi)3個(gè)，喚醒生產(chǎn)者') time.sleep(3) cond.notify() # 喚醒生產(chǎn)者線程 cond.wait() # 釋放鎖，掛起消費(fèi)者線程thd1 = Thread(target=producer)thd2 = Thread(target=customer)thd1.start()thd2.start()thd1.join() # 線程同步-等子線程結(jié)束，主線程再繼續(xù)運(yùn)行thd2.join() # 線程同步-等子線程結(jié)束，主線程再繼續(xù)運(yùn)行# 條件變量(Condition)的返回：# 連續(xù)返回："""生產(chǎn)1個(gè)，總數(shù)：1生產(chǎn)1個(gè)，總數(shù)：2生產(chǎn)1個(gè)，總數(shù)：3已達(dá)到3個(gè)，不再生產(chǎn)消費(fèi)了1個(gè)，剩余：2消費(fèi)了1個(gè)，剩余：1消費(fèi)了1個(gè)，剩余：0已消費(fèi)3個(gè)，喚醒生產(chǎn)者......"""# 解釋一下上面程序："""1、定義一個(gè)鎖 con = Condition()，這個(gè)鎖在兩個(gè)線程中共享，只能一個(gè)線程運(yùn)行2、先啟動(dòng) thd1.start()，再啟動(dòng) thd2.start()3、生產(chǎn)者線程先獲得con鎖，消費(fèi)者線程遇到con鎖，只能等待4、生產(chǎn)者在 con 鎖內(nèi)，循環(huán)3次，滿足 if num == 3: 的條件5、用 con.notify() 喚醒其他線程(消費(fèi)者線程)6、用 con.wait() 釋放鎖，并掛起當(dāng)前線程(生產(chǎn)者線程)7、消費(fèi)者線程 獲得 con 鎖，循環(huán) 3 次，滿足 if num == 0: 的條件8、用 con.notify() 喚醒其他線程(生產(chǎn)者線程)9、用 con.wait() 釋放鎖，并掛起當(dāng)前線程(消費(fèi)者線程)再進(jìn)行 4、5、6、7、8、9 步驟，反復(fù)用一個(gè)鎖控制線程的喚醒和掛起"""

2、消息隊(duì)列(queue)模式

# 生產(chǎn)者、消費(fèi)者模型(邊生產(chǎn)，邊消費(fèi))from threading import Threadimport queuedef producter(que): num = 0 while num < 3: num += 1 que.put(num) print('生產(chǎn){}'.format(num))def customer(que): while True: data = que.get() print('消費(fèi){}'.format(data))que = queue.Queue()t1 = Thread(target=producter,args=(que,))t2 = Thread(target=customer,args=(que,))t1.start()t2.start()# 打印返回：以下打印不一定按照順序來的"""生產(chǎn)1生產(chǎn)2消費(fèi)1生產(chǎn)3消費(fèi)2消費(fèi)3"""

3、協(xié)成方式(yield)

# 協(xié)程函數(shù)# 接收數(shù)據(jù)并處理def customer(): while True: n = yield # 接收生產(chǎn)者消息 print('消費(fèi)：{}'.format(n))# 發(fā)送給生成器數(shù)據(jù)def producer(c): c.send(None) # 第一次啟動(dòng)生成器必須發(fā)送None，等價(jià)于 r = next(c) for i in range(1,3): print('生產(chǎn)：{}'.format(i)) # 生成器外部 接收生成器 多次返回出來的值 r = c.send(i)c = customer()producer(c) # 兩個(gè)函數(shù)產(chǎn)生關(guān)系。把生成器作為參數(shù)傳入# 打印返回:"""生產(chǎn)：1消費(fèi)：1生產(chǎn)：2消費(fèi)：2"""

總結(jié)

以上是生活随笔為你收集整理的主线程 唤醒_python线程之九：生产者消费者3种方式，2个线程1个协程的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

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