黑松山资源网 Design By www.paidiu.com
第一种使用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之两种模式的生产者消费者模型详解就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
黑松山资源网 Design By www.paidiu.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
黑松山资源网 Design By www.paidiu.com
暂无评论...
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
2024年10月08日
2024年10月08日
- 《丁当 20首重量级歌曲 Fu Good 下一站天后 2CD》[WAV/分轨][650MB]
- 歌莉雅.2012-My.Voice.Story【环星】【FLAC分轨】
- 群星.1993-一曲成名·青春无悔【飞碟】【WAV+CUE】
- 刘德华.2000-爱无知(金装版)【NEWMELODY】【WAV+CUE】
- 许巍《时光漫步》1CD[FLAC/分轨][804.3MB]
- 群星《2024第一季度百度歌曲排行抖音榜top100》1CD[FLAC/分轨][2.3GB]
- 张柏芝《全新经验》[FLAC/分轨][450MB]
- 唐朝.2008-浪漫骑士【音乐家】【WAV+CUE】
- 张芸京.2016-失败的高歌【泡耳音乐】【WAV+CUE】
- 群星.1991-音乐工厂1·皇后大道东【音乐工厂】【WAV+CUE】
- 群星.1992-音乐工厂2·首都【音乐工厂】【WAV+CUE】
- 群星.1994-音乐工厂3·儿童乐园【音乐工厂】【WAV+CUE】
- 胡鸿钧.2021-ex:CHANGE【星梦娱乐】【WAV+CUE】
- 班得瑞原装进口《第一张新世纪专辑:仙境》1CD[APE/CUE分轨][292.3MB]
- 伍佰《摇滚教父 伍佰黄金精选 2CD》[WAV+CUE][990MB]