清除队列中的所有项目

Question

我怎样才能清除队列。例如，我在队列中有数据，但由于某种原因我不需要现有数据，只想清除队列。

有什么办法吗？这行得通吗：

oldQueue = Queue.Queue()

Answer 1

q = Queue.Queue()
q.queue.clear()

编辑
为了清楚和简洁起见，我省略了线程安全的问题，但@Dan D 是相当正确的，以下更好。

q = Queue.Queue()
with q.mutex:
    q.queue.clear()

Answer 2

您只是无法清除队列，因为每个 put 还会添加 unfinished_tasks 成员。
连接方法取决于该值。
并且 all_tasks_done 也需要被通知。

with q.mutex:
    q.queue.clear()
    q.all_tasks_done.notify_all()
    q.unfinished_tasks = 0

或者以适当的方式，使用 get 和 task_done 对来安全地清除任务。

    while not q.empty():
        try:
            q.get(block=False)
        except Empty:
            continue
        q.task_done()

或者只是创建一个新队列并删除旧队列。

Answer 3

这对我来说似乎做得很好。我欢迎评论/补充，以防我错过任何重要的内容。

class Queue(queue.Queue):
  '''
  A custom queue subclass that provides a :meth:`clear` method.
  '''

  def clear(self):
    '''
    Clears all items from the queue.
    '''

    with self.mutex:
      unfinished = self.unfinished_tasks - len(self.queue)
      if unfinished <= 0:
        if unfinished < 0:
          raise ValueError('task_done() called too many times')
        self.all_tasks_done.notify_all()
      self.unfinished_tasks = unfinished
      self.queue.clear()
      self.not_full.notify_all()

Answer 4

仅使用公共 API：

try:
    while True:
        self.queue.get(False)
except queue.Empty:
    pass

Answer 5

如果您只想要一个空队列，并且不关心旧队列的垃圾收集，只需使用相同的句柄实例化一个新队列即可。例如，

    q = Queue(maxsize=max_size)
    q.put(1)
    q.put(2)
    q.put(3)
    q.put(4)

现在为了使该队列为空，您可以简单地编写以下内容。

    q = Queue(maxsize=max_size)

此时您应该有一个空队列。