Keyboard unterbrechbaren Sperr Warteschlange in Python

Question

Es scheint

import Queue 

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

Tastatur unterbrechbar ist (ctrl-c) während

import Queue 

Queue.Queue().get() 

nicht. Ich könnte immer eine Schleife erstellen;

import Queue 
q = Queue() 

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

aber das scheint wie eine seltsame Sache zu tun.

Also, gibt es eine Möglichkeit, eine unbestimmte Wartezeit zu bekommen, aber die Tastatur unterbrechbar Queue.get()?

Answer 1

Queue Objekte haben dieses Verhalten, weil sie mit Condition Objekten aus dem threading-Modul sperren. Ihre Lösung ist also wirklich die einzige Möglichkeit.

Wenn Sie jedoch wirklich eine Queue Methode möchten, die dies tut, können Sie die Queue Klasse monkeypatch. Zum Beispiel:

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

Dies würde sagen wir mal Sie

q.interruptable_get() 

statt

interruptable_get(q) 

obwohl monkeypatching im Allgemeinen durch die Python-Gemeinschaft in Fällen wie diesen, da eine reguläre Funktion wird abgeraten scheint genauso gut zu sein.

Answer 2

Dies trifft möglicherweise nicht auf Ihren Anwendungsfall zu. Aber ich habe dieses Muster in mehreren Fällen erfolgreich verwendet: (skizzenhaft und wahrscheinlich fehlerhaft, aber Sie bekommen den Punkt).

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