利用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()