¿Cómo se iteran los elementos Queue.Queue en Python?

Question

¿Alguien sabe una forma pitónica de iterar sobre los elementos de Queue.Queuesin eliminándolos de la cola. Tengo un programa de tipo productor/consumidor en el que los elementos que se procesarán se pasan utilizando un Queue.Queue, y deseo poder imprimir cuáles son los artículos restantes. ¿Algunas ideas?

Answer 1

Puede recorrer más de una copia del almacén de datos subyacente:

for elem in list(q.queue) 

Apesar de esto no pasa por las cerraduras de objetos de cola, la copia de la lista es una operación atómica y debería funcionar bien.

Si desea mantener los bloqueos, ¿por qué no retira todas las tareas de la lista, copia la lista y luego vuelve a colocarlas?

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

Usted puede subclase queue.Queue para lograr esto de una manera segura para los subprocesos:

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

elementos de cola de venta sin consumirlos:

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

Después de la operación, se obtiene todavía procesarlos :

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