Python 2.7中如何在n秒后终止Pool中的所有进程？

当然可以搞定这个需求！我给你分两种场景——进程池（multiprocessing.Pool）和线程池，都给你对应实现方案，完全适配你给出的代码结构。

一、用multiprocessing.Pool实现定时终止 #

Pool本身没有直接的超时终止API，但我们可以借助threading.Timer来实现“n秒后强制终止所有进程”的逻辑。具体思路是启动一个定时器，到点后调用进程池的terminate()方法（这个方法会立刻终止所有子进程，不管任务有没有完成）。

直接上代码：

from multiprocessing import Pool
import threading

def f(x):
    return x*x

def kill_pool(pool):
    print(f"超时触发！正在终止进程池所有进程...")
    pool.terminate()  # 强制终止所有子进程
    pool.join()

if __name__ == "__main__":
    timeout = 5  # 你要设置的超时秒数n
    p = Pool(5)
    
    # 启动定时器，n秒后执行终止操作
    timer = threading.Timer(timeout, kill_pool, args=(p,))
    timer.start()
    
    try:
        # 执行你的任务
        result = p.map(f, [1,2,3])
        print(f"任务提前完成，结果：{result}")
        # 任务完成了就取消定时器，避免误杀
        timer.cancel()
    finally:
        # 确保进程池被正确清理
        p.close()
        p.join()

这里要注意：

• terminate()是强制终止，会直接杀掉所有子进程，适合你需要“到点就停”的场景；如果想让正在执行的任务做完再停，可以把terminate()换成close()，但这样不会立刻终止，要等现有任务结束。
• 任务提前完成时一定要取消定时器，不然定时器到点还是会终止进程池。

二、线程池备选方案（更简单） #

如果可以用线程池，那实现起来更省心——concurrent.futures.ThreadPoolExecutor的map方法本身就支持timeout参数，超时会直接抛出TimeoutError，捕获后就能处理终止逻辑。

代码示例：

from concurrent.futures import ThreadPoolExecutor, TimeoutError

def f(x):
    return x*x

if __name__ == "__main__":
    timeout = 5
    with ThreadPoolExecutor(max_workers=5) as executor:
        try:
            # 直接给map加timeout参数，超时就抛出异常
            result = list(executor.map(f, [1,2,3], timeout=timeout))
            print(f"任务执行完成，结果：{result}")
        except TimeoutError:
            print(f"超时！终止线程池所有任务")
            # with块退出时会自动关闭线程池，无需手动处理

要是你用的是multiprocessing.pool.ThreadPool（另一种线程池实现），它的map没有自带超时，这时候就可以复用进程池的定时器方案，逻辑完全一样，只是把Pool换成ThreadPool就行。

额外小提示 #

• 进程池强制终止可能会有资源泄漏风险（比如未关闭的文件、网络连接），如果你的任务涉及这类操作，最好在f(x)里加上异常处理，确保资源能正常释放。
• 线程池因为共享进程内存，终止线程相对安全，但也要注意线程内的资源清理。
• 如果你用Python 3.3+，concurrent.futures.ProcessPoolExecutor也支持map的timeout，用法和线程池一样，也可以作为multiprocessing.Pool的替代选项。

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