在使用 ThreadPoolExecutor 时，直接捕获 KeyboardInterrupt 往往失效——因为主线程被阻塞在 executor.map() 等待所有子线程完成，而信号无法及时传递或中断正在运行的线程；解决方案是将线程池执行逻辑置于独立进程内，并由主线程监控该进程，从而实现可响应的 Ctrl+C 中断。
在使用 `threadpoolexecutor` 时，直接捕获 `keyboardinterrupt` 往往失效——因为主线程被阻塞在 `executor.map()` 等待所有子线程完成，而信号无法及时传递或中断正在运行的线程；解决方案是将线程池执行逻辑置于独立进程内，并由主线程监控该进程，从而实现可响应的 ctrl+c 中断。
KeyboardInterrupt（即 Ctrl+C）在 Python 多线程程序中常表现“失灵”，尤其当使用 concurrent.futures.ThreadPoolExecutor 时。根本原因在于：主线程在 executor.map() 或 executor.submit().result() 等阻塞调用中挂起，此时即使操作系统成功发送 SIGINT 信号，Python 的信号处理器也无法立即触发异常——它必须等待当前阻塞操作返回后才得以处理。更关键的是，ThreadPoolExecutor 中的工作线程默认忽略 KeyboardInterrupt，且无法被强制中断（Python 线程不支持安全的外部终止），导致整个程序看似“卡死”。
以下是一个典型失效示例（如问题中所示）：
from concurrent.futures import ThreadPoolExecutor
def sleeper(n):
while True: # 无限循环，模拟长时间任务
pass
def run():
try:
with ThreadPoolExecutor(max_workers=10) as executor:
results = executor.map(sleeper, range(120)) # 此处阻塞，Ctrl+C 无效
except KeyboardInterrupt:
print("Interrupted!") # 永远不会执行
exit()
该代码中，executor.map() 会一直等待全部 120 个 sleeper 任务完成（而它们永不结束），因此 except KeyboardInterrupt 完全无法被捕获。
✅ 正确做法：将线程池逻辑封装进独立子进程（multiprocessing.Process），由主线程轮询其存活状态并主动终止。这样，主线程始终保持响应能力，能即时捕获 KeyboardInterrupt 并调用 process.terminate() 强制结束整个工作进程（包括其内部所有线程），避免资源残留。
改进后的可靠实现如下：
import time
from concurrent.futures import ThreadPoolExecutor
from multiprocessing import Process
def sleeper(n):
print(f"Sleeper started for {n}")
time.sleep(0.25) # 替换为实际耗时逻辑（避免无限循环）
return n
def run():
with ThreadPoolExecutor(max_workers=10) as executor:
results = list(executor.map(sleeper, range(500))) # 注意：map 返回迭代器，需 list() 触发执行
return results
if __name__ == "__main__":
process = Process(target=run)
process.start()
try:
while process.is_alive():
time.sleep(0.1) # 轻量轮询，避免忙等待
except KeyboardInterrupt:
print("\n⚠️ Received KeyboardInterrupt — terminating worker process...")
process.terminate() # 立即终止子进程及其所有线程
process.join(timeout=2) # 等待最多2秒，确保清理完成
if process.is_alive():
process.kill() # 强制杀死（极端情况兜底）
print("❗ Process forcefully killed.")
print("✅ Clean shutdown completed.")
? 关键要点与注意事项：
- ✅ Process 是信号响应的“边界”：主线程可自由捕获 KeyboardInterrupt，而子进程内的线程池无需修改即可正常运行；
- ⚠️ 避免无限循环（如 while True: pass）：这不仅使 Ctrl+C 失效，还可能拖垮系统；真实场景应结合超时、条件退出或 threading.Event 控制；
- ? executor.map() 返回惰性迭代器，若未消费（如未转为 list() 或遍历），任务甚至不会真正启动；
- ? 始终调用 process.join() + timeout，防止僵尸进程；必要时用 kill() 作为安全兜底；
- ? 若需跨进程通信或结果反馈，可结合 multiprocessing.Queue 或 Manager，但本方案聚焦“可中断性”，保持简洁。
通过进程隔离 + 主动终止，我们绕过了线程模型对信号处理的天然限制，实现了真正健壮、用户友好的中断体验——这也是生产环境中推荐的标准实践。
