Как очистить многопроцессорную очередь в python

Question

Я просто хочу знать, как очистить очередь многопроцессорности в python, как обычная очередь python. Например:

from multiprocessing import Queue # multiprocessing queue 
from Queue import Queue   # normal queue 

multi_q = Queue() 
normal_q = Queue() 
multi_q.clear()     # or multi_q.queue.clear() 

объект 'Очередь' не имеет атрибута 'ясный'

normal_q.queue.clear() # This is ok 

Answer 1

Там нет прямого способа очистки multiprocessing.Queue.

Я считаю, что ближайший у вас есть close(), но это просто говорит о том, что больше нет данных для этой очереди и будет закрыто, когда все данные будут сброшены в трубу.

Answer 2

Итак, я беру взгляд на класс Queue, и вы можете попробовать этот код:

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

Answer 3

Есть встроенный класс отсутствующего метод, который вы хотите? Подкласс встроенного класса и добавьте метод, который, по вашему мнению, должен быть там!

from Queue import Queue, Empty 

class ClearableQueue(Queue): 

    def clear(self): 
     try: 
      while True: 
       self.get_nowait() 
     except Empty: 
      pass 

Ваш ClearableQueue класс наследует все добро (и поведение) от встроенного Queue класса и имеет метод, который вы теперь хотите.

Просто используйте q = ClearableQueue() во всех местах, где вы использовали q = Queue(), и позвоните по телефону q.clear(), если хотите.