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

Atas ialah kandungan terperinci 利用python生成器实现生产者消费者模型的方法介绍. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!