南强小屋 Design By 杰米
第一种使用queue队列实现：
#生产者消费者模型 其实服务器集群就是这个模型
# 这里介绍的是非yield方法实现过程
import threading,time
import queue
q = 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之两种模式的生产者消费者模型详解就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。
标签：
Python,生产者,消费者
南强小屋 Design By 杰米
广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
免责声明：本站文章均来自网站采集或用户投稿，网站不提供任何软件下载或自行开发的软件！ 如有用户或公司发现本站内容信息存在侵权行为，请邮件告知！ 858582#qq.com
南强小屋 Design By 杰米
暂无Python之两种模式的生产者消费者模型详解的评论...
稳了！魔兽国服回归的3条重磅消息！官宣时间再确认！
昨天有一位朋友在大神群里分享，自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址，com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后，确实是网易的网址，也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情，因为以前都没有出现这样的情况，现在突然提示跳转到国服战网的网址，是不是说明了简体中文客户端已经开始进行更新了呢？