首页 > 代码库 > 4.利用python生成器实现简单的“生产者消费者”模型

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


本文出自 “reBiRTH” 博客,请务必保留此出处http://suhaozhi.blog.51cto.com/7272298/1908969

4.利用python生成器实现简单的“生产者消费者”模型