python 的生產者和消費者模式
python 的生產者和消費者模式
一、生產者消費者模式概述
在并發(fā)編程中使用生產者和消費者模式能夠解決大不多的并發(fā)問題。該模式通過平衡生產線程和消費線程的工作能力來提高程序的整體處理數據的速度。
二、為什么使用生產者消費者模式
在線程世界里,生產者就是生產數據的線程,消費者就是消費數據的線程。在多線程開發(fā)中,如果生產者處理速度很快,而消費者處理速度很慢,那么生產者就必須等待消費者處理完才能繼續(xù)生產數據。同樣的道理,如果消費者的處理能力大于生產者,那么消費者就必須等待生產者。為了解決這個問題引入了生產者和消費者模式。
三、什么是生產者消費者模式
生產者消費者模式是通過一個容器來解決生產者和消費者的強耦合問題。生產者和消費者彼此之間不直接通訊,而通過阻塞隊列來進行通訊,所以生產者生產完數據之后不用通過等待消費者處理,直接扔給阻塞隊列,消費者不著生產者拿數據,而是直接從阻塞隊列中取,阻塞隊列相當于一個緩沖區(qū),平衡了生產者和消費者的處理能力。

四、代碼案例
1、定義一個生產者
import threading
import queue
import time
#定義一個生產者
def producer():
count = 0
#判斷隊列中任務的數量
while q.qsize()<5:
print('第%s頓飯......',count)
q.put(count)
count+=1
time.sleep(1)
2、定義一個消費者
import threading
import queue
import time
#定義一個消費者
def consumer(name):
while True:
print("%s 吃了第%s飯" % (name,q.get()))
3、定義一個隊列
import threading
import queue
import time
#定義一個隊列
q = queue.Queue(maxsize=4)
t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer,args=('jibu',))
t1.start()
t2.start()
結果:
第%s頓飯...... 0 jibu 吃了第0飯 第%s頓飯...... 1 jibu 吃了第1飯 第%s頓飯...... 2 jibu 吃了第2飯 第%s頓飯...... 3 jibu 吃了第3飯 第%s頓飯...... 4 jibu 吃了第4飯 第%s頓飯...... 5 jibu 吃了第5飯 第%s頓飯...... 6 jibu 吃了第6飯 第%s頓飯...... 7 jibu 吃了第7飯 第%s頓飯...... 8 # 另外,如果供大于求或者求大于供,可以在相對小的一方在增加線程的數量
當然如果需要進一步優(yōu)化可以讓消費者執(zhí)行完隊列中所有任務的時候告訴生產者一聲
import threading
import queue
import time
#定義一個生產者
def producer():
count = 0
#判斷隊列中任務的數量
for i in range(5):
print('第%s頓飯......',count)
q.put(count)
count+=1
time.sleep(1)
q.join()
#定義一個消費者
def consumer(name):
while True:
print("%s 吃了第%s飯" % (name,q.get()))
q.task_done()
print('消費者執(zhí)行完了所有任務')
#定義一個隊列
q = queue.Queue(maxsize=4)
t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer,args=('jibu',))
t1.start()
t2.start()
結果
第0頓飯......
jibu 吃了第0飯
消費者執(zhí)行完了所有任務
第1頓飯......
jibu 吃了第1飯
消費者執(zhí)行完了所有任務
第2頓飯......
jibu 吃了第2飯
消費者執(zhí)行完了所有任務
第3頓飯......
jibu 吃了第3飯
消費者執(zhí)行完了所有任務
第4頓飯......
jibu 吃了第4飯
消費者執(zhí)行完了所有任務
結論:
生產者消費者的2個主要作用
- 程序的解耦合
- 程序的異步執(zhí)行,提高了程序的運行效率(在排隊的時候可以做別的事,過一會可以回來拿這個結果)
到此這篇關于python 的生產者和消費者模式的文章就介紹到這了,更多相關python生產者消費者模式內容請搜索本站以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持本站!
版權聲明:本站文章來源標注為YINGSOO的內容版權均為本站所有,歡迎引用、轉載,請保持原文完整并注明來源及原文鏈接。禁止復制或仿造本網站,禁止在非maisonbaluchon.cn所屬的服務器上建立鏡像,否則將依法追究法律責任。本站部分內容來源于網友推薦、互聯網收集整理而來,僅供學習參考,不代表本站立場,如有內容涉嫌侵權,請聯系alex-e#qq.com處理。
關注官方微信