程序终止时ThreadPoolExecutor任务未正常结束致冻结，求解决方案

ThreadPoolExecutor的工作线程默认是非守护线程，一旦任务开始执行：

• future.cancel() 仅对未启动的任务生效，任务运行后调用完全无效；
• executor.shutdown(wait=False) 只是让主线程不等待线程池关闭，但工作线程会继续执行完任务；
• sys.exit() 仅终止主线程，非守护线程会持续运行直到任务结束，导致程序无法正常退出。

方案1：使用守护线程（Python 3.10+） #

通过自定义线程工厂，让线程池创建守护线程。主线程结束时，守护线程会被强制终止，无需等待任务完成。

from concurrent.futures import ThreadPoolExecutor
from threading import Thread
from time import sleep

def task():
    for i in range(3):
        print(i)
        sleep(1)

# 自定义守护线程工厂
def daemon_thread_factory():
    thread = Thread()
    thread.daemon = True
    return thread

with ThreadPoolExecutor(thread_factory=daemon_thread_factory) as executor:
    future = executor.submit(task)
    # 主线程结束时，守护线程会被强制终止

方案2：使用终止信号（全版本兼容，更安全） #

通过threading.Event创建终止信号，让任务定期检查信号并主动退出。这种方式避免强制终止线程带来的资源泄漏风险，是更推荐的安全方案。

from concurrent.futures import ThreadPoolExecutor
from threading import Event
from time import sleep

# 创建全局终止信号
stop_task = Event()

def task():
    for i in range(3):
        # 检查终止信号，若已触发则退出
        if stop_task.is_set():
            print("任务主动终止")
            break
        print(i)
        sleep(1)

with ThreadPoolExecutor() as executor:
    future = executor.submit(task)
    
    # 触发终止信号
    stop_task.set()
    executor.shutdown(wait=False)

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