python之生产者消费者模型实现详解
作者:bainianminguo 发布时间:2021-12-03 14:37:15
标签:python,生产者,消费者,模型
代码及注释如下
#Auther Bob
#--*--conding:utf-8 --*--
#生产者消费者模型,这里的例子是这样的,有一个厨师在做包子,有一个顾客在吃包子,有一个服务员在储存包子,这个服务员我们就可以用queue来实现
import threading
import queue
import time
'''
def consumer(p,que):
id = que.get()
print("[%s]来吃包子了,我吃到的包子的名字是[%s]" %(p,id))
def prodcer(p,que):
print("[%s]做了2个包子" %(p))
que.put("baozi[1]")
print("baozi[1]做好了")
que.put("baozi[2]")
print("baozi[2]做好了")
if __name__ == '__main__':
que = queue.Queue()
p = threading.Thread(target=prodcer,args=("Bob",que))
c1 = threading.Thread(target=consumer,args=("c1",que))
c2 = threading.Thread(target=consumer, args=("c2", que))
c3 = threading.Thread(target=consumer, args=("c3", que))
p.start()
c1.start()
c2.start()
c3.start()
# p.join()
'''
#上面这个例子,如果没有包子了,但是厨师会不知道,厨师也不会继续做包子,而没有吃到包子的人会一直等待,程序会一直不结束
#我们可以这样做,消费者发现没有包子了,告诉服务员,服务员在告诉厨师,这里我们就会遇到task.down
def consumer(p):
id = que.get()
print("[%s]来吃包子了,我吃到的包子的名字是[%s]" %(p,id))
que.task_done() #如归队列为空了,则会通知que.join,que.join就不会阻塞了
"""
def prodcer(p):
while True:
if que.qsize() < 3:
# time.sleep(1)
for i in range(2):
print("[%s]做了包子[%d]" %(p,i))
que.put(i)
que.join() #如果队列一直不为空,则que.join会一直阻塞,如果队列为空,则que.join就不阻塞了
"""
def prodcer(p):
while True:
# time.sleep(1)
for i in range(2):
print("[%s]做了包子[%d]" %(p,i))
que.put(i)
que.join() #如果队列一直不为空,则que.join会一直阻塞,如果队列为空,则que.join就不阻塞了
if __name__ == '__main__':
que = queue.Queue()
p = threading.Thread(target=prodcer,args=("Bob1",))
p2 = threading.Thread(target=prodcer, args=("Bob2",))
c1 = threading.Thread(target=consumer,args=("c1",))
c2 = threading.Thread(target=consumer, args=("c2",))
c3 = threading.Thread(target=consumer, args=("c3",))
c4 = threading.Thread(target=consumer, args=("c4",))
c5 = threading.Thread(target=consumer, args=("c5",))
c6 = threading.Thread(target=consumer, args=("c6",))
p.start()
p2.start()
c1.start()
c2.start()
c3.start()
c4.start()
c5.start()
c6.start()
# p.join()
# que.task_done()
来源:https://www.cnblogs.com/bainianminguo/p/7426273.html
0
投稿
猜你喜欢
- ASP具备动态输出任一Office应用程序文件格式的功能。在开始编写代码之前,我们首先需要做的就是设置正确的文件类型,因为浏览器需要知道如何
- 简介TensorFlow 是一个端到端开源机器学习平台。它拥有一个全面而灵活的生态系统,其中包含各种工具、库和社区资源,可助力研究人员推动先
- 本文实例为大家分享了python实现登录与注册系统的具体代码,供大家参考,具体内容如下实现功能1.调用文本文件里的用户信息2.可以将注册信息
- python版本和ssl版本都会导致 requests在请求https网站时候会出一些错误,最好使用新版本。1 Python2.6x use
- 最近正在用功的学习jQuery,在琢磨了不少别人写的功能之后,也开始尝试着自己开发一些功能。今天我做了一个简单的密码强度测试工具。这可功能的
- 问题描述我在用Keras的Embedding层做nlp相关的实现时,发现了一个神奇的问题,先上代码:a = Input(shape=[15]
- 实际参数在函数中我们可以使用 arguments 对象获得 (注:形参可通过 arguments.callee 获得),虽然 argumen
- 当管理SQL Server内在的帐户和密码时,我们很容易认为这一切都相当的安全。但实际上并非如此。在这里,我们列出了一些对于SQL Serv
- 爬一个网页时,要保存的数据都没有encode,就导致保存下来的中文都变成unicode了。。。那么,怎么把一个表示字符串的unicode还原
- 字符串的表示方式单引号 ' '双引号 " "多引号 """ "&
- 前言本文主要给大家介绍了关于python用队列asyncio.Queue通讯的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详
- 本文实例讲述了Python实现的文本简单可逆加密算法。分享给大家供大家参考,具体如下:其实很简单,就是把一段文本每个字符都通过某种方式改变(
- 可能许多同学对SQL Server的备份和还原有一些了解,也可能经常使用备份和还原功能,我相信除DBA之外我们大部分开发员队伍对备份和还原只
- 目录相关背景直方图计算法图像指纹与汉明距离平均哈希法(aHash)感知哈希算法(pHash)dHash算法在网上看到python做图像识别的
- 本文实例讲述了php实现mysql事务处理的方法。分享给大家供大家参考。具体分析如下:要实现本功能的条件是环境 mysql 5.2 /php
- 前言:Python smtplib 教程:展示了如何使用 smtplib 模块在 Python 中发送电子邮件。 要发送电子邮件,我们使用
- 一、决策树原理决策树是用样本的属性作为结点,用属性的取值作为分支的树结构。 决策树的根结点是所有样本中信息量最大的属性。树的中间结点是该结点
- 本文实例讲述了Python实现方便使用的级联进度信息的方法。分享给大家供大家参考。具体实现方法如下:class StepedProgress
- 有些时候,我们需要画图后的二进制数据流,matplotlib没有提供相关的api,通过源码查看与百度,得到下面此方法import matpl
- 关于段落<p></p>相信大家已经都在自己的工作中开始关注并应用了。因为那真的是非常简单的事,只要你愿意你随时都可以