le threading ignore l'exception KeyboardInterrupt

Question

J'exécute ce code simple :

import threading, time

class reqthread(threading.Thread):    
    def run(self):
        for i in range(0, 10):
            time.sleep(1)
            print('.')

try:
    thread = reqthread()
    thread.start()
except (KeyboardInterrupt, SystemExit):
    print('\n! Received keyboard interrupt, quitting threads.\n')

Mais quand je l'exécute, il imprime

$ python prova.py
.
.
^C.
.
.
.
.
.
.
.
Exception KeyboardInterrupt in <module 'threading' from '/usr/lib/python2.6/threading.pyc'> ignored

En fait, le fil de python ignore mon Ctrl + C interruption du clavier et n'imprime pas Received Keyboard Interrupt . Pourquoi ? Quel est le problème de ce code ?

Answer 1

Essayez

try:
  thread=reqthread()
  thread.daemon=True
  thread.start()
  while True: time.sleep(100)
except (KeyboardInterrupt, SystemExit):
  print '\n! Received keyboard interrupt, quitting threads.\n'

Sans l'appel à time.sleep le processus principal consiste à sortir de l'eau. try...except trop tôt, de sorte que le bloc KeyboardInterrupt n'est pas prise. Ma première idée était d'utiliser thread.join mais cela semble bloquer le processus principal (en ignorant le KeyboardInterrupt) jusqu'à ce que l'option thread est terminé.

thread.daemon=True fait en sorte que le thread se termine lorsque le processus principal se termine.

Answer 2

Pour résumer les changements recommandés dans le site commentaires le texte suivant fonctionne bien pour moi :

try:
  thread = reqthread()
  thread.start()
  while thread.isAlive(): 
    thread.join(1)  # not sure if there is an appreciable cost to this.
except (KeyboardInterrupt, SystemExit):
  print '\n! Received keyboard interrupt, quitting threads.\n'
  sys.exit()

Answer 3

Légère modification de la solution d'ubuntu.

Suppression de tread.daemon = True comme suggéré par Eric et remplacement de la boucle de sommeil par signal.pause() :

import signal
try:
  thread=reqthread()
  thread.start()
  signal.pause() # instead of: while True: time.sleep(100)
except (KeyboardInterrupt, SystemExit):
  print '\n! Received keyboard interrupt, quitting threads.\n'

Answer 4

Ma solution (bricolée) est de faire du "monkey-patch". Thread.join() comme ça :

def initThreadJoinHack():
  import threading, thread
  mainThread = threading.currentThread()
  assert isinstance(mainThread, threading._MainThread)
  mainThreadId = thread.get_ident()
  join_orig = threading.Thread.join
  def join_hacked(threadObj, timeout=None):
    """
    :type threadObj: threading.Thread
    :type timeout: float|None
    """
    if timeout is None and thread.get_ident() == mainThreadId:
      # This is a HACK for Thread.join() if we are in the main thread.
      # In that case, a Thread.join(timeout=None) would hang and even not respond to signals
      # because signals will get delivered to other threads and Python would forward
      # them for delayed handling to the main thread which hangs.
      # See CPython signalmodule.c.
      # Currently the best solution I can think of:
      while threadObj.isAlive():
        join_orig(threadObj, timeout=0.1)
    else:
      # In all other cases, we can use the original.
      join_orig(threadObj, timeout=timeout)
  threading.Thread.join = join_hacked

Answer 5

Mettre le try ... except dans chaque fil et aussi un signal.pause() en vrai main() fonctionne pour moi.

Faites attention à verrou d'importation cependant. Je suppose que c'est la raison pour laquelle Python ne résout pas le problème de ctrl-C par défaut.