`threadpoolexecutor.shutdown()` 无法强制终止已开始执行的线程；需结合 `threading.event` 主动轮询中断信号，在任务内部实现协作式取消，才能真正实现快速、安全的线程中止。
在 Python 的 concurrent.futures 模块中，ThreadPoolExecutor.shutdown(wait=False, cancel_futures=True) 仅能取消尚未开始执行的 Future，对已进入 run() 状态的线程完全无效。这是因为线程一旦启动，其执行逻辑由用户代码控制，而 Executor 本身不提供抢占式中断机制（Python 不支持 Thread.kill()）。若任务包含长耗时操作（如 sleep(i)、I/O 等），线程会持续运行直至自然结束，导致 shutdown() 后程序仍卡住。
要实现真正的“立即中止”，必须采用协作式取消（cooperative cancellation）：在任务函数中定期检查一个共享的中断信号（如 threading.Event），一旦被置位，主动退出执行。
以下是一个完整、可运行的解决方案：
from concurrent.futures import ThreadPoolExecutor, as_completed
import threading
import time
class ThreadTerminationRequired(Exception):
pass
def work(i, shutdown_event):
"""带中断检查的可取消任务"""
start = time.time()
# 模拟前置条件检查（如触发全局终止）
if 50 <= i < 100:
raise ThreadTerminationRequired
print(f"[Task {i}] Starting (duration: {i}s)")
# 替代原始 sleep(i)：分段休眠 + 实时检查中断信号
remaining = i
while remaining > 0 and not shutdown_event.is_set():
# 每次最多休眠 1 秒，便于及时响应中断
sleep_duration = min(1.0, remaining)
time.sleep(sleep_duration)
remaining -= sleep_duration
if shutdown_event.is_set():
print(f"[Task {i}] Interrupted early after {i - remaining:.1f}s")
return f"INTERRUPTED-{i}"
print(f"[Task {i}] Completed successfully")
return f"OK-{i}"
if __name__ == '__main__':
shutdown_event = threading.Event()
with ThreadPoolExecutor(max_workers=8) as executor:
# 提交所有任务，传入共享的 shutdown_event
futures = {
executor.submit(work, i, shutdown_event): i
for i in range(100)
}
try:
# 等待任意 Future 完成并获取结果
for future in as_completed(futures):
result = future.result() # 此处可能抛出 ThreadTerminationRequired
print(f"Result: {result}")
except ThreadTerminationRequired:
print("⚠️ ThreadTerminationRequired caught — initiating graceful shutdown...")
# 1. 触发全局中断信号
shutdown_event.set()
# 2. 尝试取消所有未开始的 Future（虽非必需，但更严谨）
for future in futures:
future.cancel()
# 3. 调用 shutdown — wait=False 避免阻塞，cancel_futures=True 是默认行为（Python 3.9+）
executor.shutdown(wait=False, cancel_futures=True)
print("✅ Shutdown signal sent. Waiting for active tasks to respond...")
# 可选：等待最多 5 秒确保关键任务退出（超时后可强制放弃）
shutdown_event.wait(timeout=5.0)
print("? All tasks notified. Exiting main thread.")关键要点说明：
- ✅ threading.Event 是轻量、线程安全的通信原语，适合跨线程传递“停止”信号；
- ✅ 任务内必须主动轮询 event.is_set()，且不能依赖单次长阻塞调用（如 sleep(100)）——应拆分为短周期检查；
- ✅ executor.shutdown(wait=False) 仅释放资源调度器，不终止线程；真正终止靠 Event + 任务内协作退出；
- ⚠️ 不要使用 sys.exit() 或 os._exit() 强制退出主线程：这会跳过 with 块的清理逻辑，可能导致资源泄漏或死锁；
- ? 若需“暂停/恢复”而非终止，可改用 threading.Condition 或双状态 Event（如 pause_event + resume_event）。
通过这种设计，你既能保持线程池复用性（异常后可重置 Event 并重新提交任务），又能确保中断响应时间可控（取决于轮询粒度），是生产环境中推荐的健壮实践。
