利用python生成器實現生產者消費者模型的方法介紹

import time

def producer():

pro_list = []

for i in range(10000):

print "包子%s制作ing" %(i)

time.sleep(0.5)

pro_list.append("包子%s" %i)

return pro_list

def consumer(pro_list):

for index,stuffed_bun in enumerate(pro_list):

print "第%s個人,吃了第%s個包子" %(index,stuffed_bun)

pro_list = producer()

consumer(pro_list)

上面這種生產者與消費者模型有一個嚴重的問題，就是效率極低，而且在“生產”的過程中，消費者要等待，一直等待所有的包子都生產結束，消費者才可以吃，這種模式效率低又不合理。

想要提高效率，就要對生產的過程，進行修改，生產和消費過程應該是兩個獨立的個體，生產和消費應該做到“并發”（同時）的操作。

import time

def consumer(name):

print '我是%s,準備開始吃包子了'%(name)

while True:

stuffed_bun = yield

time.sleep(1)

print "%s很開心的把%s吃掉了" %(name,stuffed_bun)

def producer():

p1 = consumer("suhaozhi")

p2 = consumer("ayumi")

p1.next() ＃執行next方法后，死循環開始

p2.next()

for i in range(10):

time.sleep(1)

p1.send("包子%s" %(i)) ＃通過send給yield賦值，yield在將值賦給stuffed_bun

p2.send("包子%s" %(i))

producer()

聲明：本網頁內容旨在傳播知識，若有侵權等問題請及時與本網聯系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com