teclado cola de bloqueo interrumpible en Python

Question

Parece

import Queue 

Queue.Queue().get(timeout=10) 

es interrumpible teclado (Ctrl-C), mientras que

import Queue 

Queue.Queue().get() 

no lo es. Siempre podría crear un bucle;

import Queue 
q = Queue() 

while True: 
    try: 
     q.get(timeout=1000) 
    except Queue.Empty: 
     pass 

pero esto parece una cosa extraña de hacer.

Entonces, ¿hay alguna manera de obtener un indefinidamente esperando pero el teclado es interrumpible Queue.get()?

Answer 1

Queue objetos tienen este comportamiento, ya que bloquean el uso de Condition objetos forman el módulo threading. Entonces, tu solución es realmente la única manera de hacerlo.

Sin embargo, si realmente quiere un método Queue que hace esto, puede monopatchear la clase Queue. Por ejemplo:

def interruptable_get(self): 
    while True: 
     try: 
      return self.get(timeout=1000) 
     except Queue.Empty: 
      pass 
Queue.interruptable_get = interruptable_get 

Esto le permitiría decir

q.interruptable_get() 

en lugar de

interruptable_get(q) 

aunque monkeypatching Normalmente se desaconseja por la comunidad Python en casos como estos, ya que una función regular parece igual de bueno.

Answer 2

Esto puede no aplicarse en absoluto a su caso de uso. Pero he utilizado con éxito este patrón en varios casos: (impreciso y probablemente con errores, pero entiendes el punto).

STOP = object() 

def consumer(q): 
    while True: 
     x = q.get() 
     if x is STOP: 
      return 
     consume(x) 

def main() 
    q = Queue() 
    c=threading.Thread(target=consumer,args=[q]) 

    try: 
     run_producer(q) 
    except KeybordInterrupt: 
     q.enqueue(STOP) 
    c.join()