ThreadPoolExecutor超时后脚本无法退出，如何实现正常退出？

我完全懂你的困扰——明明已经把ThreadPoolExecutor的线程设为daemon=True，超时后也走到了清理逻辑，但脚本就是卡着不肯退出。这其实是因为Python的daemon线程机制没法强制终止处于不可中断阻塞状态的线程，比如线程卡在了原生系统调用、死锁的锁等待，或者永远不会完成的I/O操作上。

下面给你几个可行的解决思路，按推荐程度排序：

1. 显式取消任务+立即关闭Executor #

在超时触发后，先取消所有未完成的任务，再调用shutdown(wait=False)让Executor不用等待剩余线程结束。这是最安全的常规方案：

import concurrent.futures
from concurrent.futures import TimeoutError

# 假设你的任务函数是这样的（如果能改任务逻辑，建议加上取消检查）
def your_task(...):
    # 可选：如果任务里有循环或可中断的步骤，定期检查是否被取消
    while some_condition:
        # 检查当前任务是否被取消
        if concurrent.futures.Future().cancelled():
            # 这里可以做些资源清理后退出
            return
        # 执行你的任务逻辑，尽量用带超时的阻塞调用
        try:
            result = blocking_operation(timeout=2)
        except TimeoutError:
            continue

try:
    with concurrent.futures.ThreadPoolExecutor(max_workers=32) as executor:
        workers = [executor.submit(your_task, ...) for x in work]
        try:
            for f in concurrent.futures.as_completed(workers, timeout=60):
                f.result()
        except TimeoutError:
            # 取消所有未完成的任务
            for future in workers:
                if not future.done():
                    future.cancel()
            # 立即关闭Executor，不等待剩余线程执行完毕
            executor.shutdown(wait=False)
            raise TimeoutError()
except TimeoutError:
    # 这里执行你的清理逻辑，比如关闭文件、释放连接等
    print("完成清理，准备退出脚本")

2. 给任务添加可中断机制 #

如果能修改任务函数，尽量把阻塞操作改成支持超时的版本，或者在循环中加入取消检查。比如用threading.Event来通知线程退出：

import threading

def your_task(stop_event, ...):
    while not stop_event.is_set():
        try:
            # 带超时的阻塞操作
            result = blocking_operation(timeout=1)
            # 处理结果
        except TimeoutError:
            continue
    # 收到停止信号，清理资源后退出

# 在主逻辑中：
stop_event = threading.Event()
try:
    with concurrent.futures.ThreadPoolExecutor(max_workers=32) as executor:
        workers = [executor.submit(your_task, stop_event, ...) for x in work]
        try:
            for f in concurrent.futures.as_completed(workers, timeout=60):
                f.result()
        except TimeoutError:
            # 发送停止信号给所有任务
            stop_event.set()
            executor.shutdown(wait=False)
            raise TimeoutError()
except TimeoutError:
    # 清理逻辑
    pass

3. 极端方案：强制终止线程（不推荐） #

如果上面的方法都没用，只能用非常危险的强制终止线程手段——这个方法可能导致资源泄漏、数据损坏，只建议在万不得已时使用：

import threading
import ctypes
from concurrent.futures import TimeoutError

def terminate_thread(thread):
    """强制终止线程，仅作为最后手段"""
    if not thread.is_alive():
        return
    # 向线程发送SystemExit异常
    exc = ctypes.py_object(SystemExit)
    res = ctypes.pythonapi.PyThreadState_SetAsyncExc(
        ctypes.c_long(thread.ident), exc
    )
    if res == 0:
        raise ValueError("无法找到目标线程ID")
    elif res > 1:
        # 如果设置异常失败，需要重置状态
        ctypes.pythonapi.PyThreadState_SetAsyncExc(thread.ident, None)
        raise SystemError("设置线程中断异常失败")

# 在清理逻辑中：
except TimeoutError:
    # 找到所有ThreadPoolExecutor的线程并强制终止
    for thread in threading.enumerate():
        if thread.name.startswith("ThreadPoolExecutor"):
            terminate_thread(thread)
    # 执行其他清理

为什么daemon=True还阻止退出？ #

Python的daemon线程规则是：当所有非daemon线程结束后，解释器会尝试退出，但如果daemon线程处于不可中断的阻塞状态（比如等待内核级的I/O、原生代码死循环），解释器没法强制杀死它们，只能等这些阻塞操作自然结束——这就是你遇到的核心问题。

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