파이썬에서 다중 처리 대기열을 지우는 방법

Question

일반 파이썬 대기열처럼 파이썬에서 다중 처리 대기열을 지우는 방법을 알고 싶습니다. 예를 들어 :

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

그래서, 큐 클래스에서 살펴보고, 당신은이 코드를 시도 할 수 있습니다

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 = Queue()을 사용하는 모든 곳에서 q = ClearableQueue()을 사용하고 q.clear()으로 전화하십시오.