时间:2021-05-22
第一种使用queue队列实现:
#生产者消费者模型 其实服务器集群就是这个模型# 这里介绍的是非yield方法实现过程import threading,timeimport queueq = queue.Queue(maxsize=10)def Producer(anme): # for i in range(10): # q.put('骨头%s'%i) count = 1 while True: q.put('骨头%s'%count) print('生产了骨头',count) count += 1 time.sleep(1)def Consumer(name): # while q.qsize() >0: while True: print('[%s] 取到[%s] 并且吃了它...'%(name,q.get())) time.sleep(1)p = threading.Thread(target=Producer,args=('shenchanzhe',))c = threading.Thread(target=Consumer,args=('xiaofeizhe01',))c1 = threading.Thread(target=Consumer,args=('xiaofeizhe02',))p.start()c.start()c1.start()使用yield协程的方法来实现生产者和消费者:
#生产者和消费者,使用生成器的方式,就是一个简单的并行,import time# 这是一个消费者 一直在等待完成吃包子的动作def consumer(name): print('%s准备吃包子了!'%name) #打印出对应的消费者的名字 while True: #执行一个死循环 实际上就是需要调用时才会执行,没有调用就会停止在yield baozi = yield #在它就收到内容的时候后就把内容传给baozi print('包子【%s】来了,被【%s】吃了'%(baozi,name))def producer(name): c1 = consumer('A') #它只是把c1变成一个生成器 c2 = consumer('B') c1.__next__() #第一个next只是会走到yield然后停止 c2.__next__() print('老子开始做包子了') for i in range(1,10): time.sleep(1) print('三秒做了两个包子') c1.send(i) #这一步其实就是调用next方法的同时传一个参数i给field接收,然后baozi=i c2.send(i+1) #其实这里是这样的,在send的时候只是继续执行yield下面的语句,然后去去yield,再次停在这儿# producer('aea')c = consumer('aaa') #没next一次就会将程序执行一次c.__next__()c.__next__()c.__next__()以上这篇Python之两种模式的生产者消费者模型详解就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
详解Python模拟实现生产者消费者模式的实例散仙使用python3.4模拟实现的一个生产者与消费者的例子,用到的知识有线程,队列,循环等,源码如下:Pytho
一、生产者消费者模型介绍1.1为什么需要使用生产者消费者模型生产者是指生产数据的任务,消费者是指消费数据的任务。当生产者的生产能力远大于消费者的消费能力,生产者
生产者消费者模型生产者:生产任务的个体;消费者:消费任务的个体;缓冲区:是生产者和消费者之间的媒介,对生产者和消费者解耦。当缓冲区元素为满,生产者无法生产,消费
1、生产者消费者模型作用和示例如下:1)通过平衡生产者的生产能力和消费者的消费能力来提升整个系统的运行效率,这是生产者消费者模型最重要的作用2)解耦,这是生产者
概述对于多线程程序来说,生产者和消费者模型是非常经典的模型。更加准确的说,应该叫“生产者-消费者-仓库模型”。离开了仓库,生产者、消费者就缺少了共用的存储空间,