Python多进程创建与启动的四种方式详解
本文详细讲解Python中多进程的创建与启动方法,涵盖通过Process类直接创建、使用进程池Pool管理、以及继承Process类三种核心方式。内容包含关键参数说明、代码示例及主进程等待机制,帮助开发者高效实现并发任务处理。
Python支持三种主要的并发执行模式:多进程、多线程和协程。采用并发执行的核心目的在于提升程序的整体运行效率。
一、多进程的创建方法
1、通过Process类创建多进程 Process类的语法结构如下:
Process(group, target, name, args, kwargs)
group:指定进程组,⼤多数情况下⽤不到
target:表示调用对象,即子进程要执行的任务
name:子进程的名称,可以不设定
args:给target指定的函数传递的参数,以元组的⽅式传递
kwargs:给target指定的函数传递命名参数Process类常用的方法包括:
p.start() 启动进程,并调用该子进程中的p.run()方法
p.join(timeout):主进程等待⼦进程执⾏结束再结束,timeout是可选的超时时间
is_alive():判断进程⼦进程是否还存活
p.run() 进程启动时运行的方法,正是它去调用target指定的函数
p.terminate() ⽴即终⽌⼦进程(1)首先,定义一个需要被调用的函数:
import os
from multiprocessing import Process
def add(name,num):
nums = 0
for i in range(num+1):
nums = nums+i
print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"%(name,nums,os.getpid(),os.getppid()))(2)创建并启动一个进程
def test1():
'''启动一个进程调用'''
name= '王五'
p = Process(target=add,args=(name,10,))
p.start()
p.join()其中,p.join()方法的作用是使主进程等待子进程执行完毕后再结束;若未调用此方法,主进程退出时子进程可能仍在运行。(2)创建并启动多个进程
def test3():
names = ['王五','赵六','王麻子']
process_list=[]
for name in names:
p = Process(target=add,args=(name,10,))
p.start()
process_list.append(p)
for j in process_list:
j.join()2、通过进程池创建并启动多进程
进程池允许用户指定可用进程的数量。当有新请求提交至进程池时,若池内进程数量未满,则创建新进程执行该请求;若进程数已达上限,请求将进入等待状态,直到有进程空闲出来。Pool(numprocess, initializer, initargs)参数说明:numprocess指定创建的进程数,若省略则默认为CPU最大核心数;initializer是每个工作进程启动时需执行的可调用对象;initargs是传递给initializer的参数元组,默认为None。
def test4():
from multiprocessing import Pool
'''启动多个进程2:进程池'''
p = Pool(5)
names = ['王五','赵六','王麻子']
for name in names:
p.apply_async(add,args=(name,10))
p.close()
p.join()3、通过继承Process类的方法创建多进程
(1)首先创建一个进程对象
class SubProcess(Process):
def __init__(self,name,number):
super(SubProcess, self).__init__()
self.name = name
self.number = number
def run(self):
sums = 0
for i in range(self.number):
sums = sums+i
print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"\
%(self.name,self.number,os.getpid(),os.getppid()))(2)启动一个进程
def call_Sub0():
'''启动一个进程调用'''
name = '张三'
p = SubProcess(name,10)
p.start()
p.join()(3)通过列表启动多个进程
def call_Sub1():
'''启动多个进程1'''
names = ['王五','赵六','王麻子']
process_list=[]
for name in names:
p = SubProcess(name,10)
p.start()
process_list.append(p)
for j in process_list:
j.join()
if __name__ == '__main__':
print("当前主进程id:",os.getpid())
call_Sub1()
print("计算结束!")4、进程创建与启动的完整代码示例
import os
from multiprocessing import Process
def add(name,num):
nums = 0
for i in range(num+1):
nums = nums+i
print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"%(name,nums,os.getpid(),os.getppid()))
def test1():
'''启动一个进程调用'''
name= '王五'
p = Process(target=add,args=(name,10,))
p.start()
p.join()
def test3():
'''启动多个进程2'''
names = ['王五','赵六','王麻子']
process_list=[]
for name in names:
p = Process(target=add,args=(name,10,))
p.start()
process_list.append(p)
for j in process_list:
j.join()
'''
进程池:可以提供指定数量的进程给用户使用,即当有新的请求提交到进程池中时,
如果池未满,则会创建一个新的进程用来执行该请求;反之,如果池中的进程数已经达到规定最大值,
那么该请求就会等待,只要池中有进程空闲下来,该请求就能得到执行。
'''
def test4():
from multiprocessing import Pool
'''启动多个进程2:进程池'''
p = Pool(5)
names = ['王五','赵六','王麻子']
for name in names:
p.apply_async(add,args=(name,10))
p.close()
p.join()
class SubProcess(Process):
def __init__(self,name,number):
super(SubProcess, self).__init__()
self.name = name
self.number = number
def run(self):
sums = 0
for i in range(self.number):
sums = sums+i
print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"\
%(self.name,self.number,os.getpid(),os.getppid()))
def call_Sub0():
'''启动一个进程调用'''
name = '张三'
p = SubProcess(name,10)
p.start()
p.join()
def call_Sub1():
'''启动多个进程1'''
names = ['王五','赵六','王麻子']
process_list=[]
for name in names:
p = SubProcess(name,10)
p.start()
process_list.append(p)
for j in process_list:
j.join()
if __name__ == '__main__':
print("当前主进程id:",os.getpid())
call_Sub1()
print("计算结束!")到此这篇关于Python中多进程的创建与启动的文章就介绍到这了,更多相关Python多进程创建与启动内容请搜索本站以前的文章或继续浏览下面的相关文章,希望大家以后多多支持本站!
免责声明:本文内容仅供参考,不代表本站观点。转载或引用请注明出处。









