博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
队列queue实例(生产者和消费者模型)
阅读量:5824 次
发布时间:2019-06-18

本文共 557 字,大约阅读时间需要 1 分钟。

import queue, threading, time q = queue.Queue(maxsize=10) def producter(n):     count = 1     while True:         q.put(count)         print('%s 生产了%s 骨头'%(n,count))         time.sleep(1)         count += 1 def consumer(n):     while True:         print('%s 获得了 %s 骨头'%(n,q.get()))         time.sleep(1) p = threading.Thread(target=producter, args=('alex',)) c = threading.Thread(target=consumer, args=('陈荣华',)) c1 = threading.Thread(target=consumer, args=('王森', )) p.start() c.start() c1.start()

转载于:https://www.cnblogs.com/my-love-is-python/p/9134970.html

你可能感兴趣的文章
ubuntu 修改hostname
查看>>
sql 内联,左联,右联,全联
查看>>
C++关于字符串的处理
查看>>
6、Web Service-拦截器
查看>>
Flask 源码流程,上下文管理
查看>>
stream classdesc serialVersionUID = -7218828885279815404, local class serialVersionUID = 1.
查看>>
ZAB与Paxos算法的联系与区别
查看>>
java 读取本地的json文件
查看>>
Breaking parallel loops in .NET C# using the Stop method z
查看>>
修改故障转移群集心跳时间
查看>>
[轉]redis;mongodb;memcache三者的性能比較
查看>>
微软职位内部推荐-Sr DEV
查看>>
让你的WPF程序在Win7下呈现Win8风格主题
查看>>
JDBC二查询(web基础学习笔记八)
查看>>
802.11 学习笔记
查看>>
Leetcode-Database-176-Second Highest Salary-Easy(转)
查看>>
构建Docker Compose服务堆栈
查看>>
最小角回归 LARS算法包的用法以及模型参数的选择(R语言 )
查看>>
Hadoop生态圈-Kafka常用命令总结
查看>>
如何基于Redis Replication设计并实现Redis-replicator?
查看>>