利用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()
以上就是利用python生成器实现生产者消费者模型的方法介绍的详细内容,更多请关注其它相关文章!