Python多进程：跨进程中断循环及相关技术问题咨询

需求背景 #

实现从监控进程中断被监控进程内的循环，示例代码如下：

loop1 = True
loop2 = True

def function1():
    while loop1:
        #do something
    else:
        loop1

def function2():
    while loop2:
        if something == True:
            #break loop1
            break
        else:
            loop2

def main():
    process1 = multiprocessing.Process(target=function1)
    process2 = multiprocessing.Process(target=function2)
    process1.start()
    process2.start()
    process1.join()
    process2.join()

if __name__ == '__main__':
    main()

1. 如何从function2()中断function1()中的循环？ #

多进程内存空间完全隔离，直接修改全局变量loop1对另一个进程无效，推荐用以下几种优雅方式：

• 使用multiprocessing.Event：这是最常用的进程间同步方式，创建一个事件对象传给两个进程，function1循环检查事件状态，function2触发中断时设置事件。示例代码：

  from multiprocessing import Process, Event
  
  def function1(stop_event):
      while not stop_event.is_set():
          # 执行循环任务
          pass
  
  def function2(stop_event):
      # 模拟监控逻辑，满足条件时触发中断
      something = True
      if something:
          stop_event.set()  # 设置事件，中断function1的循环
  
  def main():
      stop_event = Event()
      process1 = Process(target=function1, args=(stop_event,))
      process2 = Process(target=function2, args=(stop_event,))
      process1.start()
      process2.start()
      process1.join()
      process2.join()
  
  if __name__ == '__main__':
      main()
  

• 使用multiprocessing.Queue：function2往队列发送中断信号，function1循环检查队列是否有信号。
• 强制终止进程：如果不需要优雅收尾，可直接调用process1.terminate()，但这种方式会强制杀死进程，可能导致资源泄漏，仅适合非关键场景。

2. 中断循环后，是否代表进程完成任务并可执行join()？ #

是的。当function1的循环被中断后，函数会执行完剩余代码（如果有的话）然后退出，进程进入终止状态，此时调用join()会等待进程完全释放资源。不管是优雅中断还是强制终止，join()都能正常等待进程结束。

3. if __name__ == '__main__':是否必须？有无其他调用进程的方式？ #

在Windows系统中必须——因为Windows没有fork机制，启动子进程时会重新导入主模块，这个判断能避免无限递归创建子进程。在Unix/Linux系统中虽非强制，但加上它是跨平台兼容的最佳实践。

其他调用进程的方式：

• 使用multiprocessing.Pool：适合批量管理多进程，比如Pool.map()可自动分发任务到子进程。
• 使用concurrent.futures.ProcessPoolExecutor：更高层的封装，简化进程管理，支持异步获取结果。
• 继承multiprocessing.Process类，重写run()方法定义进程逻辑。

4. 进程执行join()后会终止还是继续？如何实现进程的终止与重启？ #

join()只是等待进程终止，本身不会让进程停止。进程会在任务执行完毕后自动终止，或被外部强制终止。

• 进程终止：
  • 优雅终止：通过事件、队列等通信方式让进程自行退出循环，结束函数执行后自然终止。
  • 强制终止：调用process.terminate()（Unix/Linux发送SIGTERM信号）或process.kill()（发送SIGKILL信号），Windows下会直接强制终止进程。
• 进程重启：进程终止后无法直接重启，需重新创建新的Process对象并调用start()。示例：

  from multiprocessing import Process
  
  def restart_process(old_process, target_func, args_tuple):
      # 确保旧进程已终止
      if old_process.is_alive():
          old_process.terminate()
          old_process.join()
      # 创建并启动新进程
      new_process = Process(target=target_func, args=args_tuple)
      new_process.start()
      return new_process
  

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