如何正确终止基于multiprocessing的持续运行Python进程

Python multiprocessing 场景下最推荐的安全停止方案是使用进程安全的终止信号标志，避免强制杀进程导致的资源泄漏，行业通用的做法如下：

首选方案：使用 multiprocessing.Event 做终止信号 #

这是跨平台兼容性最好、实现最简单的方案，核心逻辑是通过进程间共享的事件对象，通知子进程主动退出，子进程完成资源清理后自行结束。

改造后的完整实现代码： #

from multiprocessing import Process, Event
import time

# 初始化进程间共享的终止事件
stop_event = Event()
run_process = Process(target=run, args=(stop_event,))

def start_running():
    run_process.start()

def run(stop_event):
    # 循环条件直接检测终止事件状态
    while not stop_event.is_set():
        # 你的核心业务逻辑
        print("任务执行中...")
        # 若存在长时间阻塞操作，拆分后增加事件检测频率，避免无法及时响应停止信号
        # 示例：把原本1秒的休眠拆为10次0.1秒的休眠，每次都检测是否需要退出
        for _ in range(10):
            if stop_event.is_set():
                break
            time.sleep(0.1)
    # 进程退出前的清理逻辑可写在此处：关闭文件、断开数据库连接、删除临时文件等
    print("进程完成清理，正常退出")

def stop_running():
    # 触发终止信号，通知子进程退出
    stop_event.set()
    # 等待子进程完全退出后再返回
    run_process.join()

关键注意事项 #

• 不要直接使用 run_process.terminate() 强制终止进程：该方法会直接杀死子进程，不会执行任何清理逻辑，极易出现文件损坏、连接泄漏、进程间锁未释放等异常问题，仅可作为进程无响应时的最后兜底方案。
• 不要用普通全局变量作为终止标志：multiprocessing 创建的子进程会独立复制父进程的内存空间，父进程修改的普通全局变量无法同步到子进程，必须使用multiprocessing模块提供的进程间通信原语（Event、Queue等）。
• 复杂控制场景可改用 multiprocessing.Queue：如果需要给子进程传递不止停止指令的其他控制命令，可以用队列传递消息，子进程从队列读取指令后做对应处理。
• Windows平台不建议用信号处理方案：基于SIGTERM等系统信号的停止方案在Windows下兼容性较差，优先用Event实现跨平台兼容。

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