python - 如何清除 multiprocessing.Queue？

Question

我只想知道如何像 Python 中的 queue.Queue 一样清除 multiprocessing.Queue:

>>> import queue
>>> queue.Queue().clear()
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
AttributeError: 'Queue' object has no attribute 'clear'
>>> queue.Queue().queue.clear()

>>> import multiprocessing
>>> multiprocessing.Queue().clear()
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
AttributeError: 'Queue' object has no attribute 'clear'
>>> multiprocessing.Queue().queue.clear()
Traceback (most recent call last):
  File "<stdin>", line 1, in <module>
AttributeError: 'Queue' object has no attribute 'queue'

Answer 1

所以，我看一下 Queue 类，您可以试试这段代码:

while not some_queue.empty():
    some_queue.get()  # as docs say: Remove and return an item from the queue.