4.利用python生成器实现简单的“生产者消费者”模型
2017-03-21 19:50
971 查看
假如说,没有生成器这种对象,那么如何实现这种简单的“生产者消费者”模型呢?
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()
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实现生产者消费者的并发模型
- Queue、BlockingQueue以及利用BlockingQueue实现生产者/消费者模型
- 使用semaphore实现生产者-消费者简单模型
- 用BlockingQueue实现简单的生产者-消费者模型
- 分布式Web应用----基于Socket+动态代理实现简单RPC 生产者消费者模型
- 利用python线程编程实现生产者与消费者关系
- 利用多线程和信号量,互斥量实现的经典的生产者与消费者模型
- Java多线程系列-Queue、BlockingQueue以及利用BlockingQueue实现生产者/消费者模型
- 简单生产者消费者模型(java实现)
- 简单介绍Python中利用生成器实现的并发编程
- 简单介绍Python中利用生成器实现的并发编程
- 用BlockingQueue实现一个简单的生产者-消费者模型
- python生产者消费者简单模型
- 【Python之旅】第六篇(五):生产者消费者模型实现多线程异步交互
- Linux C:利用两个线程实现生产者消费者模型
- 利用两个线程实现生产者消费者模型
- Java多线程15:Queue、BlockingQueue以及利用BlockingQueue实现生产者/消费者模型
- Python3之线程Queue实现生产者消费者模型
- 11.python并发入门(part8 基于线程队列实现生产者消费者模型)
- python之函数实现生产者消费者模型(开发模型)