在Python中清空multiprocessing.queue(-1)的首选方法

Question

8

我希望能够获取当前队列中的所有项目。另一个线程不断将项目放在队列的另一端，而我想每隔一段时间获取当前队列中的所有项目。

有什么理由更喜欢以下方式吗：

res = []
while q.qsize > 0 :
    res.append(q.get())

或者

res = []
while True :
    try :
         res.append(q.get(block=False)) 
    except Queue.Empty :
         break

现在文档明确指出，qsize() > 0不能防止队列在获取时阻塞，但这只适用于多个线程可以从输出中获取的情况下。

队列.Queue.qsize() 返回大约队列的大小。请注意，qsize() > 0 不能保证随后的get()不会阻塞，而qsize() < maxsize也不能保证put()不会阻塞。

这是否意味着应始终首选第二种形式？EAFP等等? 另外，调用q.qsize() 是否有成本？它是否会阻塞队列的另一端以进行计数？

我猜我已经说服自己使用第二种形式，但它对我来说似乎不太干净。

- phil_20686

1个回答

网页内容由stack overflow 提供, 点击上面的

可以查看英文原文，
原文链接

- Phillip · Accepted Answer

是的，你应该始终使用第二种方法：API的文档（应该）比实现的未经记录的细节更可靠。即使当前的multiprocessing实现在您的特殊情况下工作正常，如果qsize() > 0，get()不会阻塞，但不能保证它将在Python的将来版本中保持这种状态，因为文档已经清楚地说明了这一点。