Python实现多进程的四种方式

Ivy

发布时间：2026-10-13| 7人浏览过

原创

本文详细解析Python中实现多进程的四种核心方式：利用os.fork()创建子进程、通过multiprocessing模块直接实例化Process、继承Process类重写run方法，以及使用进程池Pool进行任务管理。文章涵盖各方法的代码示例、适用场景及注意事项，帮助开发者根据实际需求选择高效的并发编程方案。

方式一：使用os.fork()。该函数仅在Unix系统中有效，在Windows系统中不可用。调用fork()一次会返回两次：在父进程中返回子进程的ID，在子进程中返回0。

# -*- coding:utf-8 -*-
"""
pid=os.fork()
  1.只用在Unix系统中有效，Windows系统中无效
  2.fork函数调用一次，返回两次：在父进程中返回值为子进程id，在子进程中返回值为0
"""
import os
pid=os.fork()
if pid==0:
  print("执行子进程，子进程pid={pid},父进程ppid={ppid}".format(pid=os.getpid(),ppid=os.getppid()))
else:
  print("执行父进程，子进程pid={pid},父进程ppid={ppid}".format(pid=pid,ppid=os.getpid()))

方式二：使用multiprocessing模块，通过创建Process实例并传入任务执行函数作为参数来启动进程。

# -*- coding:utf-8 -*-
"""
Process常用属性与方法：
  name:进程名
  pid：进程id
  run()，自定义子类时覆写
  start()，开启进程
  join(timeout=None)，阻塞进程
  terminate(),终止进程
  is_alive()，判断进程是否存活
"""
import os,time
from multiprocessing import Process
def worker():
  print("子进程执行中>>> pid={0},ppid={1}".format(os.getpid(),os.getppid()))
  time.sleep(2)
  print("子进程终止>>> pid={0}".format(os.getpid()))
def main():
  print("主进程执行中>>> pid={0}".format(os.getpid()))
  ps=[]
  # 创建子进程实例
  for i in range(2):
    p=Process(target=worker,name="worker"+str(i),args=())
    ps.append(p)
  # 开启进程
  for i in range(2):
    ps[i].start()
  # 阻塞进程
  for i in range(2):
    ps[i].join()
  print("主进程终止")
if __name__ == '__main__':
  main()

方式三：使用multiprocessing模块，通过派生Process的子类并重写run方法来自定义进程行为。

# -*- coding:utf-8 -*-
import os,time
from multiprocessing import Process
class MyProcess(Process):
  def __init__(self):
    Process.__init__(self)
  def run(self):
    print("子进程开始>>> pid={0},ppid={1}".format(os.getpid(),os.getppid()))
    time.sleep(2)
    print("子进程终止>>> pid={}".format(os.getpid()))
def main():
  print("主进程开始>>> pid={}".format(os.getpid()))
  myp=MyProcess()
  myp.start()
  # myp.join()
  print("主进程终止")
if __name__ == '__main__':
  main()

方式四：使用进程池Pool。通过创建指定大小的进程池，利用apply或apply_async方法异步或同步执行任务，最后关闭进程池并等待所有子进程结束。

# -*- coding:utf-8 -*-
import os,time
from multiprocessing import Pool
def worker(arg):
  print("子进程开始执行>>> pid={},ppid={},编号{}".format(os.getpid(),os.getppid(),arg))
  time.sleep(0.5)
  print("子进程终止>>> pid={},ppid={},编号{}".format(os.getpid(),os.getppid(),arg))
def main():
  print("主进程开始执行>>> pid={}".format(os.getpid()))
  ps=Pool(5)
  for i in range(10):
    # ps.apply(worker,args=(i,))     # 同步执行
    ps.apply_async(worker,args=(i,)) # 异步执行
  # 关闭进程池，停止接受其它进程
  ps.close()
  # 阻塞进程
  ps.join()
  print("主进程终止")
if __name__ == '__main__':
  main()

总结

以上就是本文的全部内容，希望这些内容对您的学习或工作具有参考价值。感谢支持，如需了解更多相关技术细节，请查阅相关链接。