Python'da çok işlemli bir kuyruk nasıl temizlenir

Question

Sadece python'da bir çok işlemli sıranın normal bir python kuyruğu gibi nasıl temizleneceğini bilmek istiyorum. Örneğin:

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

'Queue' nesne

normal_q.queue.clear() # This is ok 

Answer 1

'net' hayır niteliğini bir multiprocessing.Queue temizleyerek doğrudan bir yolu yoktur vardır.

Sahip olduğunuz en yakın olanın close() olduğuna inanıyorum, ancak bu, daha fazla verinin bu sıraya aktarılmayacağını belirtir ve tüm veriler boruya akıtıldığında onu kapatacaktır.

Answer 2

Yani, Kuyruk sınıfta göz atın ve bu kodu denemek olabilir:

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

Answer 3

mı yerleşik bir istediğiniz yöntemi eksik sınıfta? Yerleşik sınıfı alt sınıfı ve orada olması gerektiğini düşündüğünüz yöntemi ekleyin!

from Queue import Queue, Empty 

class ClearableQueue(Queue): 

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

Sizin ClearableQueue sınıfı artık istediğiniz Queue sınıfta yerleşik ve sahip yöntemin bütün iyilik (ve davranış) devralır.

q = Queue()'u kullandığınız tüm yerlerde q = ClearableQueue() kullanın ve istediğiniz zaman q.clear() numaralı telefonu arayın.