### Python 主进程如何正确停止子进程的方法 在 Python 的 `multiprocessing` 模块中，主进程可以通过多种方式来终止或停止子进程。以下是几种常见的方法及其代码实现： #### 方法一：使用 `terminate()` 方法强制终止子进程 `terminate()` 方法可以立即强制终止子进程，但需要注意的是，这种方式可能会导致资源泄漏或数据不一致的问题[^1]。 ```python import multiprocessing import time def worker(): print("Worker started") try: while True: time.sleep(1) except KeyboardInterrupt: print("Worker interrupted") if __name__ == "__main__": p = multiprocessing.Process(target=worker) p.start() time.sleep(3) # 让子进程运行一段时间 p.terminate() # 强制终止子进程 p.join() # 确保子进程已经结束 print("Worker terminated") ``` #### 方法二：通过共享标志变量优雅地停止子进程 可以通过共享的标志变量通知子进程停止其工作循环，这是一种更优雅的方式[^2]。 ```python import multiprocessing import time def worker(stop_event): print("Worker started") while not stop_event.is_set(): time.sleep(1) print("Worker is running...") print("Worker stopping") if __name__ == "__main__": stop_event = multiprocessing.Event() # 创建一个事件对象 p = multiprocessing.Process(target=worker, args=(stop_event,)) p.start() time.sleep(5) # 让子进程运行一段时间 stop_event.set() # 设置事件标志，通知子进程停止 p.join() # 等待子进程结束 print("Worker stopped gracefully") ``` #### 方法三：使用队列进行通信以控制子进程 通过 `multiprocessing.Queue` 或其他通信机制，主进程可以向子进程发送停止信号[^3]。 ```python import multiprocessing import time def worker(queue): print("Worker started") while True: if not queue.empty(): message = queue.get() if message == "STOP": print("Worker stopping") break else: print("Worker is running...") time.sleep(1) if __name__ == "__main__": queue = multiprocessing.Queue() p = multiprocessing.Process(target=worker, args=(queue,)) p.start() time.sleep(5) # 让子进程运行一段时间 queue.put("STOP") # 发送停止信号 p.join() # 等待子进程结束 print("Worker stopped gracefully") ``` #### 方法四：使用 `Pool` 和 `close()`/`terminate()` 控制进程池 当使用 `multiprocessing.Pool` 时，可以通过 `close()` 和 `terminate()` 方法来控制进程池的行为[^2]。 ```python from multiprocessing import Pool import time def worker(x): print(f"Processing {x}") time.sleep(2) return x * x if __name__ == "__main__": pool = Pool(processes=4) results = pool.map_async(worker, range(10)) time.sleep(5) # 让任务运行一段时间 pool.terminate() # 立即终止所有任务 pool.join() # 等待所有子进程结束 print("Pool terminated") ``` ### 注意事项 - 使用 `terminate()` 方法时需谨慎，因为它会直接杀死进程，可能导致资源未释放或数据丢失。 - 在需要优雅停止的情况下，推荐使用共享标志变量或队列通信的方式。 - 当处理大量任务时，建议使用 `Pool` 来管理进程，以便更高效地分配和回收资源[^2]。