Python进程创建两种方法及进程池使用详解

阿麦

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

原创

本文详解Python中创建进程的两种核心方式：通过Process类直接实例化及继承Process类重写run方法。同时深入解析进程池Pool的使用，包括进程数限制、异步任务提交apply_async、关闭进程池close及主进程等待join的关键作用，确保子进程正常执行。

在Python语言中，创建新进程主要存在两种实现路径，第一种方式如下所示：

from multiprocessing import Process
import time
 
def test():
 while True:
  print('---test---')
  time.sleep(1)
 
if __name__ == '__main__':
 p=Process(target=test)
 p.start()
 while True:
  print('---main---')
  time.sleep(1)

上述代码示例适用于Windows环境运行。通过实例化Process类可以生成一个进程对象，随后调用p.start()即可启动该进程，其中test函数定义了子进程需要执行的具体业务逻辑。

第二种创建进程的方式为：

from multiprocessing import Process
import time
 
class MyNewProcess(Process):
 def run(self):
  while True:
   print('---1---')
   time.sleep(1)
 
if __name__=='__mian__':
 p = MyNewProcess()
 # 调用p.start()方法，p会先去父类中寻找start()，然后在Process的start方法中调用run方法
 p.start()
 
 while True:
  print('---Main---')
  time.sleep(1)

这是第二种创建进程的实现机制。通过定义子类并继承Process类，子类中必须包含run方法以封装进程功能逻辑。在创建子类实例后，调用该对象的start()方法来启动进程。

接下来介绍进程池的概念，其核心目的是管理和复用已预先创建好的进程资源。

# 进程池
from multiprocessing import Pool
import os
import random
import time
 
def worker(num):
 for i in range(5):
  print('===pid=%d==num=%d='%(os.getpid(),num))
  time.sleep(1)
 
# 3表示进程池中最多有三个进程一起执行
pool=Pool(3)
 
for i in range(10):
 print('---%d---'%i)
 # 向进程中添加任务
 # 注意：如果添加的任务数量超过了进程池中进程的个数的话，那么就不会接着往进程池中添加，如果还没有执行的话，他会等待前面的进程结束，然后在往
 # 进程池中添加新进程
 pool.apply_async(worker,(i,))
 
pool.close() # 关闭进程池
pool.join() # 主进程在这里等待，只有子进程全部结束之后，在会开启主线程

从代码中可以看出，Pool方法用于初始化一个进程池，参数3代表池中允许同时存在的最大进程数量。利用pool.apply_async()将子任务异步添加到进程池中。pool.close()用于关闭进程池以阻止添加新任务，此时必须调用join()函数，否则主进程可能会直接终止，导致无法观察到进程池中子进程的运行状态。

以上关于Python中创建进程的两种具体方式以及进程池的详细解析即为全部内容，希望能为读者提供有价值的参考，同时也欢迎大家对本站给予更多支持。