Python 再次改进版通过队列实现一个生产者消费者模型
2024-10-19 00:20:32
import time
from multiprocessing import Process,Queue
#生产者
def producer(q):
for i in range(10):
time.sleep(0.2)
s = '大包子%s号'%i
print(s+'新鲜出炉,拿去用')
q.put(s)
q.put(None) #发送一个任务结束信号,来中断消费者的程序 def consumer(q):
while 1:
time.sleep(0.5)
baozi = q.get()
if baozi == None:
print('都吃完了大哥,该回家伺候嫂子了')
break
print(baozi+'被吃了') if __name__ == '__main__':
q = Queue(30) pro_p = Process(target=producer,args=(q,))
con_p = Process(target=consumer,args=(q,))
pro_p.start()
con_p.start()
最新文章
- java26
- 使用 Wireshark 调试 HTTP/2 流量
- Android studio 加速编译方法
- Binary Tree Inorder Traversal -- LeetCode 94
- win32控制台消息机制
- underscorejs-findWhere学习
- Jedis 一
- SQL - 添加外键
- maven下载,安装与eclipse中maven配置
- 第二章 js数据类型和变量
- spring学习(五) ———— 整合web项目(SSM)
- SpringBoot使用Nacos配置中心
- mysql 开发基础系列13 选择合适的数据类型(下)
- None.js 第三步 回调函数【阻塞代码--非阻塞代码】
- django 数据库html显示
- [原]Android 初遇Http错误 httpClient.execute
- 基于IE的多标签的浏览器-世界之窗2.4
- Python3 impyla 连接 hiveserver2
- cmd 使用gii的命令行用法
- 实例演示oracle数据块状态视图v$bh的用法二 热点块问题(转)