Python在main中未捕获的异常不会杀死线程[重复]

Question

当我运行 python 程序（2.7 或 3）时，我导入了一个模块，该模块具有一个初始化一些线程的类。问题是每当主线程中发生未捕获的异常时，主函数就会死掉，但线程会像僵尸一样继续运行，导致 python 进程永远不会死。

在主线程（甚至其他线程）中有任何未捕获的异常以杀死所有地方的所有内容的最佳方法是什么。

由于我经常调用subprocess模块，所以我通常使用threading.Event来帮助干净地退出。但是，未捕获的异常不会触发这些事件。

这是一个线程不会死掉的程序示例......

prog1.py

#!/usr/bin/env python2.7

import threading
import modx1

mod_obj = modx1.Moddy()

raise Exception('DIE UNEXPECTEDLY')

try:
    raise Exception('known problem here')
except Exception:
    mod_obj.kill_event.set()

modx1.py

#!/usr/bin/env python2.7

import threading
import subprocess
from time import sleep


class Moddy():
    def __init__(self):
        self.kill_event = threading.Event()
        self.my_thread=threading.Thread(target=self.thread_func)
        self.my_thread.start()
    def thread_func(self):
        while  not self.kill_event.is_set():
            print('thread still going....')
            sleep(2)

Answer 1

这似乎很老套，但还是要开始。

prog1.py - 我添加了 5 秒的睡眠时间，因此您可以看到线程正在运行，然后完成。

import modx1
import time


mod_obj = modx1.Moddy()
time.sleep(5)
raise Exception('DIE UNEXPECTEDLY')

try:
    raise Exception('known problem here')
except Exception:
    mod_obj.kill_event.set()

modx1.py -> 检查您设置的布尔值以及主线程的状态。

import ctypes
import threading
import subprocess
from time import sleep


class Moddy():
    def __init__(self):
        self.kill_event = threading.Event()
        self.my_thread = threading.Thread(target=self.thread_func)
        self.my_thread.start()

    def thread_func(self):
        while not self.kill_event.is_set() and threading.main_thread().is_alive():
            print('thread still going....')
            sleep(2)

输出

thread still going....
thread still going....
thread still going....
Traceback (most recent call last):
  File "/Users/gaurishankarbadola/PycharmProjects/untitled1/prog1.py", line 8, in <module>
    raise Exception('DIE UNEXPECTEDLY')
Exception: DIE UNEXPECTEDLY

Process finished with exit code 1

Answer 2

假设您不依赖线程中发生的清理，最简单的解决方案是将所有线程作为守护线程启动； Python 程序在所有非守护线程都完成后退出，因此如果您的主线程是唯一的非守护线程，则程序将在主线程完成时终止。

所需的更改是微不足道的，只需更改：

self.my_thread=threading.Thread(target=self.thread_func)

到：

self.my_thread=threading.Thread(target=self.thread_func, daemon=True)

线程将作为守护进程启动。

如果您确实有必须进行的清理并且在程序终止时不是自动的（例如，通过网络向远程机器发送一些“我完成了”的消息，无论出于何种原因，简单地关闭连接都是不够的），daemon 将不起作用（线程被强制终止，无论它们在中间），所以你可以使用你的方法，你只需要扩展 try 块以覆盖所有代码线程被启动，所以处理总是发生。我还建议 set-ing Event 在 finally 块中，而不是 except 块中，如果您想始终告诉线程进行清理，而不仅仅是在发生不好的事情时。如果它应该只在异常情况下完成，我会使用一个裸except: 块，并在设置Event 后明确地重新raise，例如：

try:
    # Entire program after thread launches
except:
    mod_obj.kill_event.set()
    raise  # Reraises exception as if it were never caught, rather than silencing it