Comment intercepter les exceptions d'un thread enfant dans le thread principal ?

Détection des exceptions d'un fil de discussion enfant dans le fil de discussion principal

Lorsque vous travaillez avec une programmation multithread, il est essentiel de gérer les exceptions de manière appropriée. Dans le cas de Python, un problème courant survient lorsque l'on tente d'intercepter les exceptions levées dans un thread enfant dans le thread principal.

Comprendre le problème

Le code fourni tente pour gérer les exceptions dans un thread enfant dans le bloc try-sauf dans le thread principal. Cependant, cette approche échoue car la méthode thread_obj.start() s'exécute immédiatement dans son propre contexte et sa propre pile. Toutes les exceptions générées dans le fil de discussion enfant résident dans son propre contexte, ce qui rend difficile leur détection directement dans le fil de discussion principal.

Technique de transmission de messages

Une solution possible pour ce problème consiste à utiliser un mécanisme de transmission de messages entre les threads enfants et principaux. Cette approche permet au thread enfant de communiquer les exceptions au thread principal.

Implémentation du code

Le code suivant montre comment implémenter cette technique de transmission de messages à l'aide d'une file d'attente :

import sys
import threading
import queue

class ExcThread(threading.Thread):

    def __init__(self, bucket):
        threading.Thread.__init__(self)
        self.bucket = bucket

    def run(self):
        try:
            raise Exception('An error occured here.')
        except Exception:
            self.bucket.put(sys.exc_info())


def main():
    bucket = queue.Queue()
    thread_obj = ExcThread(bucket)
    thread_obj.start()

    while True:
        try:
            exc = bucket.get(block=False)
        except queue.Empty:
            pass
        else:
            exc_type, exc_obj, exc_trace = exc
            # deal with the exception
            print exc_type, exc_obj
            print exc_trace

        thread_obj.join(0.1)
        if thread_obj.isAlive():
            continue
        else:
            break


if __name__ == '__main__':
    main()

Dans ce code :

• La classe ExcThread est un thread enfant qui lève un exception.
• Le bucket est une file d'attente qui sert de canal de communication entre les threads enfants et principaux.
• Le thread principal vérifie en permanence le bucket pour toute exception.
• Si une exception est trouvée dans le bucket, le thread principal la gère et l'imprime.
• Une fois l'exécution du thread enfant terminée, le thread principal se joint à it.

En utilisant cette méthode, les exceptions générées dans le thread enfant peuvent être efficacement communiquées et gérées dans le thread principal, permettant une gestion appropriée des exceptions dans les applications multithread.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!