Python中文
首页
教程
问答
标签
搜索
登录
注册
这个生产者消费者代码有什么问题?
回答此问题可获得
20
贡献值,回答如果被采纳可获得
50
分。
<p>我修改了<a href="http://www.java2s.com/Tutorial/Python/0340__Thread/Multiplethreadsproducingconsumingvalues.htm" rel="nofollow">an example with threads</a>并得到了下面包含多处理的示例。我的问题是ProduceToQueue运行良好,但是consumerfromqueue没有完成。为什么?这是我的第一个多处理程序之一,所以请耐心等待。在</p> <pre><code>from Queue import Queue import multiprocessing import random import time class ProduceToQueue(multiprocessing.Process): def __init__(self, queue): multiprocessing.Process.__init__(self) self.shared_queue = queue def run(self): for i in range(11, 21): time.sleep(random.randrange(5)) print "%s adding %s to queue" % (self.name, i) self.shared_queue.put(i) print self.name, "finished producing values" print "Terminating", self.name class ConsumeFromQueue(multiprocessing.Process): def __init__(self, queue): multiprocessing.Process.__init__(self) self.shared_queue = queue def run(self): value = 0 current = 10 for i in range(10): time.sleep(random.randrange(3)) print "%s attempting to read %s..." % (self.name, current + 1) current = self.shared_queue.get() print "%s read %s" % (self.name, current) value += current print "%s retrieved values totaling: %d" % (self.name, value) print "Terminating", self.name queue = Queue() producer = ProduceToQueue(queue) consumer = ConsumeFromQueue(queue) producer.start() consumer.start() producer.join() consumer.join() </code></pre>
0 条评论
分类:
Python问答
请先
登录
后评论
默认排序
时间排序
1 个回答
匿名
1天前
擅长:python、mysql、java
<p>您正在使用<code>Queue.Queue</code>。对于多处理的内容,您应该使用<a href="http://docs.python.org/library/multiprocessing.html#multiprocessing.Queue" rel="nofollow">^{<cd2>}</a>。在</p>
请先
登录
后评论
针对此问题:
更多的回答
关注
89
关注
收藏
1
收藏,
216
浏览
网友 提问于 2天前
相关Python问题
为什么在使用strptime时会出现未进行转换的数据错误?
6 回答
为什么在使用strptim时会出现这个datetime日期错误
7 回答
为什么在使用StyleFrame时索引列的标题不显示sf.至excel()?
3 回答
为什么在使用sum()函数时会发生“int”对象不可调用的错误?
5 回答
为什么在使用sympy.dsolve时会得到“'list'对象没有属性'func'”?
6 回答
为什么在使用tabla时会得到一个空的数据帧?
1 回答
为什么在使用tensorboard时需要add_graph()的第二个参数?
2 回答
为什么在使用TensorFlow Lite转换YOLOv4时,推断时间/大小没有改进?有什么可能的改进吗?
8 回答
为什么在使用Tensorflow加载训练批时会出现内存泄漏?
7 回答
为什么在使用tensorflow时会收到警告/错误(使用函数API,但未实现错误)
5 回答
为什么在使用tetpyclient发出POST请求时出现403错误?
9 回答
为什么在使用TextBlob时会出现HTTP错误?
10 回答
为什么在使用TFIDF时出现错误“IndexError:list index out of range”pyspark.ml.feature?
4 回答
为什么在使用timedelta格式化之后,我在python中的日期是错误的?
1 回答
为什么在使用timeit或exec函数时,函数中的变量不会在提供的全局命名空间中搜索?
2 回答
为什么在使用tkinter时不能使用复选框?
1 回答
为什么在使用todoistpythonapi时会返回这个奇怪的ID?
7 回答
为什么在使用TQM时,在调整图像大小时,处理时间会有很大的差异?
2 回答
为什么在使用Tweepy下载用户时间线时收到错误消息
3 回答
为什么在使用twitter帐户登录Django应用程序时重定向127.0.0.1:8000?
9 回答