Jak wyczyścić kolejkę wieloprocesową w pythonie

Question

Po prostu chcę wiedzieć, jak wyczyścić kolejkę wieloprocesową w pythonie jak normalna kolejka Pythona. Na przykład:

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() 

obiekt 'kolejce' nie ma atrybutu 'jasny'

normal_q.queue.clear() # This is ok 

Answer 1

nie ma bezpośredniego sposobu usuwania multiprocessing.Queue.

Uważam, że najbliższy jest close(), ale po prostu stwierdza, że ​​żadne dane nie zostaną przekazane do tej kolejki i zamknie je, gdy wszystkie dane zostaną przepłukane do potoku.

Answer 2

Więc biorę spojrzenie na klasy kolejki i można wypróbować ten kod:

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

Answer 3

to wbudowany w klasie brakującej metody chcesz? Podklasuj klasę wbudowaną i dodaj metodę, która Twoim zdaniem powinna tam być!

from Queue import Queue, Empty 

class ClearableQueue(Queue): 

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

Twoja klasa ClearableQueue dziedziczy całą dobroć (i zachowanie) z wbudowanym Queue klasy i ma sposobu chcesz teraz.

Po prostu użyj q = ClearableQueue() we wszystkich miejscach, w których używałeś q = Queue() i dzwonisz pod numer q.clear(), kiedy chcesz.