Cách xóa hàng đợi đa xử lý trong python

Question

Tôi chỉ muốn biết cách xóa hàng đợi đa xử lý trong python như hàng đợi python bình thường. Ví dụ:

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

đối tượng 'Queue' không có thuộc tính 'rõ ràng'

normal_q.queue.clear() # This is ok 

Answer 1

Không có cách nào trực tiếp thanh toán bù trừ một multiprocessing.Queue.

Tôi tin rằng gần nhất bạn có là close(), nhưng điều đó chỉ đơn giản nói rằng không có thêm dữ liệu nào sẽ được đẩy vào hàng đợi đó và sẽ đóng nó khi tất cả dữ liệu đã được flushed vào đường ống.

Answer 2

Vì vậy, tôi đi xem lớp Queue, và bạn có thể thử mã này:

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

Answer 3

Là một built-in Class thiếu phương pháp mà bạn muốn? Phân lớp lớp dựng sẵn và thêm phương thức mà bạn nghĩ sẽ có ở đó!

from Queue import Queue, Empty 

class ClearableQueue(Queue): 

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

lớp ClearableQueue của bạn được thừa hưởng tất cả sự tốt lành (và hành vi) của built-in Queue lớp, và có phương pháp bây giờ bạn muốn.

Chỉ cần sử dụng q = ClearableQueue() ở tất cả các nơi bạn đã sử dụng q = Queue() và gọi q.clear() khi bạn muốn.