Python 线程 - 当主线程引发异常时处理线程

Question

我有一个从数据采集设备读取数据的线程。当我的主函数崩溃时，它不会杀死数据采集线程。如果线程外出现异常，如何停止数据采集？

我的程序的简化版本是：

class Daq_reader():
    def __init__(self):
        self.keepReading = True
        self.data = []

    def acquire(self):
        while self.keepReading:
            self.data = append_new_data(data)
            time.sleep(1)

def main():
    reader = Daq_reader()
    daq_thread = threading.Thread(target=reader.acquire, daemon=True)
    daq_thread.start()

    # rest of program here that might crash

我尝试使用守护进程为 True 和 False。谢谢你！

Answer 1

看起来你想杀死你的线程。您可以使用python-worker（链接）来创建和中止该工人。

from worker import worker

class Daq_reader():
    def __init__(self):
        self.keepReading = True
        self.data = []

    @worker
    def acquire(self):
        while self.keepReading:
            self.data = append_new_data(data)
            time.sleep(1)

def main():
    try:
        reader = Daq_reader()
        reader_woker = reader.acquire()
    except:
        reader_woker.abort()

当您使用 @worker 装饰时，您的 reader.acquire() 将自动在后台运行