个人中心
文章发布
退出
作者热门文章
- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
27
4
CFSDN坚持开源创造价值，我们致力于搭建一个资源共享平台，让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Queue 实现生产者消费者模型(实例讲解)由作者收集整理，如果你对这篇文章有兴趣，记得点赞哟.
Python中，队列是线程间最常用的交换数据的形式.
Python Queue模块有三种队列及构造函数
1、Python Queue模块的FIFO队列先进先出。 class Queue.Queue(maxsize) 。
2、LIFO类似于堆，即先进后出。 class Queue.LifoQueue(maxsize) 。
3、还有一种是优先级队列级别越低越先出来。 class Queue.PriorityQueue(maxsize) 。
此包中的常用方法(q = Queue.Queue())
q.qsize() 返回队列的大小 。
q.empty() 如果队列为空，返回True,反之False 。
q.full() 如果队列满了，返回True,反之False 。
q.full 与 maxsize 大小对应 。
q.get([block[, timeout]]) 获取队列，timeout等待时间 。
q.get_nowait() 相当q.get(False) 。
非阻塞 q.put(item) 写入队列，timeout等待时间 。
q.put_nowait(item) 相当q.put(item, False) 。
q.task_done() 在完成一项工作之后，q.task_done() 函数向任务已经完成的队列发送一个信号 。
q.join() 实际上意味着等到队列为空，再执行别的操作 。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
|
# coding=utf-8
import Queue
import threading
import time
q = Queue.Queue(maxsize=10) # 创建一个队列对象，长度限制为10，maxsize小于1就代表无限制
def producer(name):
count = 1
while True:
q.put(count) # 将值放入队列中 默认block为True，无数据时调用线程暂停，否则抛出异常
print "%s 生产了包子 %d" % (name, count)
count += 1
time.sleep(0.5)
def consumer(name):
while True:
conut_con = q.get() # 从队列中取值 默认block为True，无数据时调用线程暂停，否则抛出异常
print "%s 吃掉了包子 %d" % (name, conut_con)
time.sleep(2)
pro = threading.Thread(target=producer, args=("德源",))
con = threading.Thread(target=consumer, args=("xu",))
con2 = threading.Thread(target=consumer, args=("sx",))
pro.start()
con.start()
con2.start() # 开启线程
|
以上这篇Queue 实现生产者消费者模型(实例讲解)就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持我.
原文链接：http://www.cnblogs.com/xu-xiaofeng/archive/2017/11/12/7823511.html 。
最后此篇关于Queue 实现生产者消费者模型(实例讲解)的文章就讲到这里了,如果你想了解更多关于Queue 实现生产者消费者模型(实例讲解)的内容请搜索CFSDN的文章或继续浏览相关文章，希望大家以后支持我的博客！ 。
27
4
0
我试图弄清楚以下模块正在做什么。 import Queue import multiprocessing import threading class BufferedReadQueue(Queue.
如果我使用 Queue.Queue，那么我的 read() 函数不起作用，为什么？但是，如果我使用 multiprocessing.Queue，它运行良好: from multiprocessing
我正在寻找比我在文档中找到的更多关于 Python 队列实现的见解。 根据我的理解，如果我在这方面有误，请原谅我的无知: queue.Queue():通过内存中的基本数组实现，因此不能在多个进程之间共
当我使用多处理模块(Windows 上的 Python 2.7)中的队列代替 Queue.Queue 时，我的程序没有完全关闭。 最终，我想使用 multiprocessing.Process 处理
阅读了大量的 JavaScript 事件循环教程，我看到了不同的术语来标识队列存储消息，当调用堆栈为空时，事件循环准备好获取消息: 队列 消息队列 事件队列 我找不到规范的术语来识别它。 甚至 MDN
我收到错误消息“类型队列不接受参数”。当我将更改队列行替换为 PriorityQueue 时，此错误消失并且编译正常。有什么区别以及如何将其更改为编译队列和常规队列？ import java.util
如何将项目返回到 queue.Queue？如果任务失败，这在线程或多处理中很有用，这样任务就不会丢失。 docs for queue.Queue.get()说函数可以“从队列中删除并返回一个项目”，但
如何在多个 queue.Queue 上进行“选择”同时？ Golang 有 desired feature及其 channel : select { case i1 = 声明。 线程:queue 模
http://docs.python.org/2/library/queue.html#Queue.Queue.put 这似乎是一个幼稚的问题，但我在文档和谷歌搜索中都没有找到答案，那么这些方法是线程
这可能是个愚蠢的问题，但我对与 .dequeue() 和 $.queue() 一起使用的 .queue() 感到困惑> 或 jquery.queue()。 它们是否相同，如果是，为什么 jquery
我正在尝试创建一个线程化的 tcp 流处理程序类线程和主线程对话，但是 Queue.Queue 也没有做我需要的，服务器从另一个程序接收数据，我只想传递它进入主线程进行处理这里是我到目前为止的代码:
The principal challenge of multi-threaded applications is coordinating threads that share data or ot
在Queue模块的queue类中，有几个方法，分别是qsize、empty 和 full，其文档声称它们“不可靠”。 他们到底有什么不可靠的地方？ 我确实注意到 on the Python docs网
我需要一个队列，多个线程可以将内容放入其中，并且多个线程可以从中读取。 Python 至少有两个队列类，Queue.Queue 和 collections.deque，前者似乎在内部使用后者。两者都在
明天我将介绍我选择进程内消息队列实现的基本原理，但我无法阐明我的推理。我的合作设计者提议我们实现一个简单的异步队列，只使用基本的作业列表和互斥锁来控制访问，我建议在嵌入式模式下使用 ActiveMQ。
在 scala 中定义了一个特征: trait Queue[T] Queue 是一种类型吗？或其他东西，例如类型构造函数？ 来自 http://artima.com/pins1ed/type-para
我看到 SML/NJ 包含一个队列结构。我不知道如何使用它。如何使用 SML/NJ 提供的附加库？ 最佳答案 Queue structure SML '97 未指定，但它存在于 SML/NJ 的顶级环
我是 D3 和 JavaScript 的新手。 我试图理解其中的 queue.js。 我已经完成了 this关联。但是仍然无法清楚地了解 queue.await() 和 queue.awaitAll(
所以我试图在我的 main.cpp 文件中调用一个函数，但我得到“错误:没有匹配函数来调用‘Queue::Queue()。” 队列.h #ifndef QUEUE_H #define QUEUE_H
假设我有一个 10 行的二维 numpy 数组 例如 array([[ 23425. , 521331.40625], [ 23465. , 521246.03125],
我是一名优秀的程序员,十分优秀！