python concurrent.futures.timeoutError 杀死进程

在Python的concurrent.futures模块中，`TimeoutError`异常通常会在`ThreadPoolExecutor`或`ProcessPoolExecutor`中使用`submit()`或`call()`方法时发生，当给定的任务超过指定的超时时未完成，系统就会抛出这个错误。这表示线程池或进程池中的某个任务耗时过长，超过了你设置的默认超时时间。

如果你想要在遇到`TimeoutError`时优雅地处理并终止进程，可以这样做：

from concurrent.futures import TimeoutError, ProcessPoolExecutor

def long_running_task():
    # 长时间运行的代码...

with ProcessPoolExecutor() as executor:
    future = executor.submit(long_running_task, timeout=5)  # 设置超时时间为5秒

try:
    result = future.result()
except TimeoutError:
    print("Task timed out, killing the process...")
    executor.shutdown(wait=False)  # 使用shutdown关闭进程池，不等待已提交的任务完成

在这个例子中，如果`long_running_task()`在5秒内没有结束，程序会捕获到`TimeoutError`，然后立即终止剩余的进程。注意`wait=False`参数告诉`shutdown`方法不等待当前任务执行完毕就停止所有工作。