Python 生產者與消費者模型

定義：

在併發程式設計中使用生產者和消費者模式能夠解決絕大多數併發問題。該模式通過平衡生產線程和消費執行緒的工作能力來提高程式的整體處理資料的速度。

為什麼要使用生產者和消費者模式

什麼是生產者消費者模式

生產者消費者模式是通過乙個容器來解決生產者和消費者的強耦合問題。生產者和消費者彼此之間不直接通訊，而通過阻塞佇列來進行通訊，所以生產者生產完資料之後不用等待消費者處理，直接扔給阻塞佇列，消費者不找生產者要資料，而是直接從阻塞佇列裡取，阻塞佇列就相當於乙個緩衝區，平衡了生產者和消費者的處理能力。

基於佇列實現生產者消費者模型

例項：主要用了joinablequeue進行佇列的訪問，但它有兩個方法乙個為task_done每執行一次就記錄一次直到佇列中沒有東西,另乙個join就是等到佇列中為空為止,實現生產者生產完等消費者取東西，直到取完就結束生產者本身的程序，而主程序則等生產者結束就結束，而消費者設為守護程序，主程序一結束，消費者也隨之結束

from multiprocessing import process, joinablequeue
import time, os
def producer(q, name):
for i in range(3):
time.sleep(1)
res = '%s%s' % (name, i)
q.put(res)
print('\033[45m 生產了 [%s]\033[0m' % (os.getpid(), res))
q.join() #等消費者取完就結束
def consumer(q):
while true:
res = q.get()
time.sleep(1.5)
print('\033[34m 吃了 [%s]\033[0m' % (os.getpid(), res))
q.task_done() #每取走乙個就記一次
if __name__ == '__main__':
q = joinablequeue()
# 生產者們：即廚師們
p1 = process(target=producer, args=(q, '包子'))
p2 = process(target=producer, args=(q, '餃子'))
p3 = process(target=producer, args=(q, '餛飩'))
# 消費者們：即吃貨們
c1 = process(target=consumer, args=(q,))
c2 = process(target=consumer, args=(q,))
c1.daemon=true # 設為守護程序，當主程序結束，消費者程序也隨之結束
c2.daemon=true # 設為守護程序，當主程序結束，消費者程序也隨之結束
p1.start()
p2.start()
p3.start()
c1.start()
c2.start()
p1.join() # 主程序等生產者結束
print('主')

Python 生產者與消費者模型

python生產者與消費者模型

Python 生產者消費者模型

Python 生產者消費者模型

Python 生產者與消費者模型

python生產者與消費者模型

Python 生產者消費者模型

Python 生產者 消費者模型

相關推薦

Python 生產者消費者模型