Python线程无法被安全强制终止，threading.Timer不能杀线程；唯一可靠方式是用multiprocessing.Process配合terminate()，通过Queue传递结果，支持超时抛出TimeoutError。
超时装饰器为什么不能用 threading.Timer 直接杀线程
Python 的线程无法被安全强制终止，threading.Timer 或 threading.Thread 的 stop() 方法根本不存在。试图用 _thread.exit() 或信号中断主线程会引发 SystemError 或直接崩溃。真实场景中，超时必须靠「协作式中断」或「子进程隔离」实现。
推荐路径只有一条：用 multiprocessing.Process 启动子进程，主进程用 join(timeout=...) 等待，超时后调用 terminate() —— 这是唯一可靠终止失控计算的方式。
- 不适用
asyncio.wait_for：仅限协程函数，对同步阻塞操作（如正则回溯、C 扩展死循环）无效 - 避免
signal.alarm：Windows 不支持，且会干扰同进程其他 signal 使用（如time.sleep被中断） - 子进程有开销，但换来的是确定性；若函数本身很轻量，应先评估是否真需要超时，而非硬套装饰器
使用 multiprocessing 实现可传参、可返回值的超时装饰器
核心难点在于子进程如何把结果/异常传回主进程。不能依赖全局变量或闭包（进程间内存不共享），必须用 multiprocessing.Queue 或 multiprocessing.Pipe。
以下是最简可用版本（支持位置/关键字参数、返回值、超时抛出 TimeoutError）：
from multiprocessing import Process, Queue
import time
<p>def timeout(seconds):
def decorator(func):
def wrapper(*args, **kwargs):
result_queue = Queue()</p><pre class="brush:php;toolbar:false;"> def _target():
try:
ret = func(*args, **kwargs)
result_queue.put(('success', ret))
except Exception as e:
result_queue.put(('error', e))
p = Process(target=_target)
p.start()
p.join(timeout=seconds)
if p.is_alive():
p.terminate()
p.join() # 确保进程资源释放
raise TimeoutError(f'Function {func.__name__} timed out after {seconds}s')
status, value = result_queue.get_nowait()
if status == 'success':
return value
else:
raise value
return wrapper
return decorator
- 必须用
result_queue.get_nowait()：因为子进程已结束，队列必有且仅有一个结果 -
p.join()在terminate()后必须调用，否则僵尸进程残留 - 装饰器内部不能引用外层作用域的非基本类型变量（如 list/dict），否则在子进程中 unpickle 失败
为什么 timeout 装饰器不能装饰类方法或 lambda
子进程通过 pickle 序列化函数对象传递，而 lambda、嵌套函数、类实例方法（self.xxx）默认不可 pickle —— 会报 AttributeError: Can't pickle local object 或 PicklingError。
- ✅ 可用：模块顶层定义的普通函数（
def my_func(): ...） - ❌ 不可用：
lambda x: x * 2、class A: def method(self): ...、def outer(): return lambda: 1 - 变通方案：将逻辑拆出为顶层函数，再在方法中调用；或改用
dill库（但增加依赖且不保证 100% 兼容）
超时精度与实际延迟的差距在哪
子进程启动 + IPC 通信本身就有毫秒级开销，join(timeout=0.1) 实际可能耗时 10–50ms 更多。更严重的是：若目标函数在超时前已开始执行但未完成，terminate() 会立即结束进程，导致中间状态（如文件写入、数据库事务）不一致。
- 不要对有副作用的操作加超时装饰器（比如写文件、发 HTTP 请求）
- 若必须控制 I/O 类操作，优先用原生超时参数（如
requests.get(..., timeout=5)、socket.settimeout()） - 子进程被
terminate()后，其打开的文件句柄、网络连接等由操作系统回收，但 Python 层无法触发__exit__或finally块
真正难的从来不是“怎么加超时”，而是“加了之后系统是否还处于可预期状态”。多数线上服务里，一个没做幂等保护的超时重试，比不加超时更危险。
Python免费学习笔记（深入）：立即使用
在学习笔记中，你将探索 Python 的核心概念和高级技巧！
