Python 创建多进程执行多任务
一、进程的创建步骤
- 导入进程包
- 通过进程类创建进程对象
- 进程对象 = multiprocessing.Process(target=任务名)
参数名 |
说明 |
target |
执行的目标任务名,这里指的是函数名或方法名 |
name |
进程名,一般不设置 |
group |
进程组,目前只能使用None |
- 启动进程执行任务
二、进程创建与启动的代码
# 导入进程包
import multiprocessing
# 创建任务函数
def func1(a):
print(a)
def func2(b):
print(b)
# 创建子进程1
process_1 = multiprocessing.Process(target=func1, args=(a, ))
# 创建子进程2
process_2 = multiprocessing.Process(target=func2, args=(b, ))
# 启动进程
process_1.start()
process_2.start()
# 等待进程结束
process_1.join()
process_2.join()
三、进程执行带有参数的任务
参数名 |
说明 |
args |
以元组的方式给执行任务传参 |
kwargs |
以字典的方式给执行任务传参 |
# target: 进程执行的函数名
# args: 表示以元组的方式给函数传参
process_1 = multiprocessing.Process(target=func1, args=(a, ) # a 表示传入的参数
process_1.start()
# target: 线程执行函数名
# kwargs:表示以字典的方式给函数传参
process_1 = multiprocessing.Process(target=function, kwargs=("name":"xiaoming"))
process_1.start()