Python父进程终止时如何关闭子监听线程？

1. 将子线程设为守护线程 #

这是最直接的处理方式：Python的守护线程会在主线程（父任务）终止时自动退出。只需在创建线程时添加daemon=True参数：

self.listenerTask = threading.Thread(target=self.listener, name="Listener", args=[interface], daemon=True)

注意：如果子线程持有需要手动释放的资源（比如USB/BLE接口连接），这种方式可能来不及执行清理代码，需要结合下面的超时检查方案。

2. 定期检测父线程状态+可中断阻塞 #

你的监听逻辑里用了timeout=None的阻塞调用，即使父线程终止，子线程也会卡在阻塞调用里无法退出。可以给readMsg设置短超时，让循环定期检查父线程是否存活：

def listener(self, interface):
    logger.info(f"Listener started, threadid={threading.get_ident()}")
    # 获取主线程（父任务所在线程）
    parent_thread = threading.main_thread()
    
    # 创建并复用事件循环，比反复调用asyncio.run更高效
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    
    try:
        # 同时检查自定义停止标志和父线程状态
        while not self.stopListener and parent_thread.is_alive():
            try:
                # 设置1秒超时，让循环有机会检查退出条件
                responseMsg = loop.run_until_complete(interface.readMsg(timeout=1))
                if responseMsg:
                    # 处理收到的消息
                    ...
            except asyncio.TimeoutError:
                # 超时属于正常情况，继续循环
                continue
            except Exception as e:
                logger.error(f"Listener error: {e}")
                break
    finally:
        # 确保资源被清理
        loop.close()
        interface.close()

3. 用Threading.Event替代布尔标志 #

threading.Event比自定义的self.stopListener布尔变量更线程安全，适合多线程间的信号传递。父任务可以在正常退出时调用self.stop_event.set()，同时结合父线程存活检测处理意外终止：

# 父任务中初始化事件
self.stop_event = threading.Event()
self.listenerTask = threading.Thread(target=self.listener, name="Listener", args=[interface, self.stop_event], daemon=True)

# 监听线程代码
def listener(self, interface, stop_event):
    logger.info(f"Listener started, threadid={threading.get_ident()}")
    parent_thread = threading.main_thread()
    loop = asyncio.new_event_loop()
    asyncio.set_event_loop(loop)
    
    try:
        # 等待事件被设置或父线程死亡，超时时间和readMsg一致
        while not stop_event.is_set() and parent_thread.is_alive():
            try:
                responseMsg = loop.run_until_complete(interface.readMsg(timeout=1))
                if responseMsg:
                    ...
            except asyncio.TimeoutError:
                continue
            except Exception as e:
                logger.error(f"Listener error: {e}")
                break
    finally:
        loop.close()
        interface.close()

最优方案建议 #

优先选择守护线程+超时检查+资源清理的组合：

• 守护线程保证父任务意外终止时子线程能最终退出；
• 短超时让子线程有机会定期检查退出条件；
• 最终块确保USB/BLE接口等资源被正确释放，避免资源泄漏。

内容的提问来源于stack exchange，提问作者wdtj