Jak iterować elementy Queue.Queue w języku Python?

Question

Czy ktoś zna pyton sposób iteracji elementów Queue.Queuebez usuwanie ich z kolejki. Mam program typu producent/konsument, w którym przedmioty do przetworzenia są przekazywane za pomocą numeru Queue.Queue i chcę móc wydrukować pozostałe elementy. Jakieś pomysły?

Answer 1

Można pętli nad kopią bazowego magazynu danych:

for elem in list(q.queue) 

Eventhough ten omija blokady dla obiektów kolejce, lista kopia jest operacją atomową i powinien wypracować w porządku.

Jeśli chcesz zachować blokady, może nie wyciągać wszystkich zadań z kolejki, tworzyć listę, a następnie je odkładać.

mycopy = [] 
while True: 
    try: 
     elem = q.get(block=False) 
    except Empty: 
     break 
    else: 
     mycopy.append(elem) 
for elem in mycopy: 
    q.put(elem) 
for elem in mycopy: 
    # do something with the elements 

Answer 2

Można podklasy queue.Queue do osiągnięcia tego celu w wątku bezpieczny sposób:

import queue 


class ImprovedQueue(queue.Queue): 
    def to_list(self): 
     """ 
     Returns a copy of all items in the queue without removing them. 
     """ 

     with self.mutex: 
      return list(self.queue) 

Answer 3

elementów kolejek Zamieszczone bez ich spożywania:

>>> from Queue import Queue 
>>> q = Queue() 
>>> q.put(1) 
>>> q.put(2) 
>>> q.put(3) 
>>> print list(q.queue) 
[1, 2, 3] 

Po zakończeniu pracy, można się nadal je przetwarzać :

>>> q.get() 
1 
>>> print list(q.queue) 
[2, 3]