python - 如何在不删除的情况下提取多处理队列元素

Question

由于 AutoProxy 错误，我无法提取多处理队列的元素。

提取队列元素而不删除的正常方法是执行 - list(q.queue) where q-> queue object。似乎不适用于 MP 队列。

import multiprocessing as mp

q = mp.Manager().Queue(maxsize=20)

list(q)

TypeError: 'AutoProxy[Queue]' object is not iterable

list(q.queue)

AttributeError: 'AutoProxy[Queue]' object has no attribute 'queue'

list(q.queue.queue)

AttributeError: 'AutoProxy[Queue]' object has no attribute 'queue'

当我使用时也会发生同样的情况：

q = mp.Queue(maxsize=20)

我希望能够在不执行 q.get() 的情况下提取队列元素，并且希望继续使用共享队列，因为它被多个进程使用。

score 0 · Accepted Answer

对于多处理的队列..

q = Queue()
q.put(2)
q.put(4)

elements = list()
while q.qsize():
    elements.append(q.get())
print(elements)

1 回答 1