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

4.1什麼是生產者消費者模式

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

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

線上程世界力，生產者就是生產資料的執行緒，消費者就是消費資料的執行緒。在多執行緒開發中，如果生產者處理速度很快，而消費者處理速度很慢，那麼生產者就必須等待消費者處理完，才能繼續生產資料。同樣的道理，如果消費者的處理能力大於生產者，那麼消費者就必須等待生產者。為了解決這個問題於是引入了生產者和消費者模式。

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

from multiprocessing import Process,Queue
import time,random,os
def consumer(q):
    while True:
        res=q.get()
        time.sleep(random.randint(1,3))
        print('%s 吃 %s' %(os.getpid(),res))
 
 
def producer(q):
    for i in range(10):
        time.sleep(random.randint(1,3))
        res='
 
包子%s' %i
        q.put(res)
        print('生產了 %s' %(os.getpid(),res))
 
 
if __name__ == '__main__':
    q=Queue()
    #生產者們:即廚師們
    p1=Process(target=producer,args=(q,))
 
 
    #消費者們:即吃貨們
    c1=Process(target=consumer,args=(q,))
 
 
    #開始
    p1.start()
    c1.start()
    print('主')