Python并发进程—multiprocessing 模块创建进程

Posted 2021-12-28 maplethefox

multiprocessing 模块创建进程

进程创建方法

1.流程特点
【1】 将需要子进程执行的事件封装为函数
【2】 通过模块的Process类创建进程对象，关联函数
【3】 可以通过进程对象设置进程信息及属性
【4】 通过进程对象调用start启动进程
【5】 通过进程对象调用join回收进程

2.基本接口使用

Process()

• 功能 ： 创建进程对象
• 参数 ： target 绑定要执行的目标函数 
• 　　　　rgs 元组，用于给target函数位置传参
• 　　　　kwargs 字典，给target函数键值传参

p.start()

• 功能 ： 启动进程

注意:启动进程此时target绑定函数开始执行，该函数作为子进程执行内容，此时进程真正被创建

p.join([timeout])

• 功能：阻塞等待回收进程
• 参数：超时时间

注意

• 使用multiprocessing创建进程同样是子进程复制父进程空间代码段，父子进程运行互不影响。
• 子进程只运行target绑定的函数部分，其余内容均是父进程执行内容。
• multiprocessing中父进程往往只用来创建子进程回收子进程，具体事件由子进程完成。
• multiprocessing创建的子进程中无法使用标准输入

 1 import multiprocessing as mp
 2 from time import sleep
 3 
 4 a = 1
 5 
 6 def fun():
 7   print("开始一个新的进程")
 8   sleep(5)
 9   global  a
10   print("a = ",a)
11   a = 10000
12   print("子进程结束了")
13 
14 # 创建进程对象
15 p = mp.Process(target = fun)
16 p.start()  # 启动进程
17 
18 sleep(2)
19 print("父进程干点啥")
20 
21 p.join(1) # 回收进程
22 
23 print(‘a:‘,a)
24 
25 # 等价于如下
26 # pid = os.fork()
27 # if pid == 0:
28 #   fun()
29 # else:
30 #   os.wait()

multiprocessing 示例1

 1 from multiprocessing import Process
 2 from time import sleep
 3 import os
 4 
 5 def th1():
 6   sleep(3)
 7   print("吃饭")
 8   print(os.getppid(),‘---‘,os.getpid())
 9 
10 def th2():
11   sleep(2)
12   print("睡觉")
13   print(os.getppid(),‘---‘,os.getpid())
14 
15 def th3():
16   sleep(4)
17   print("打豆豆")
18   print(os.getppid(),‘---‘,os.getpid())
19 
20 things = [th1,th2,th3]
21 jobs = []
22 for th in things:
23   p = Process(target = th)
24   p.start()
25   jobs.append(p)  # 将进程对象保存在列表
26 
27 # 一起回收
28 for i in jobs:
29   i.join()

multiprocessing 示例2

 1 from multiprocessing import Process
 2 from time import sleep
 3 
 4 # 带参数的进程函数
 5 def worker(sec,name):
 6   for i in range(3):
 7     sleep(sec)
 8     print("I‘m %s"%name)
 9     print("I‘m working ... ")
10 
11 # p = Process(target=worker,args=(2,‘Baron‘))
12 p = Process(target = worker,args=(2,),
13             kwargs=‘name‘:‘Baron‘)
14 p.start()
15 p.join()

multiprocessing 示例3

3.进程对象属性

p.name 进程名称

p.pid 对应子进程的PID号

p.is_alive() 查看子进程是否在生命周期

p.daemon 设置父子进程的退出关系

• 如果设置为True则子进程会随父进程的退出而结束
• 要求必须在start()前设置
• 如果daemon设置成True 通常就不会使用 join()

 1 from multiprocessing import Process
 2 from time import sleep,ctime
 3 
 4 def tm():
 5   for i in range(3):
 6     sleep(2)
 7     print(ctime())
 8 
 9 p = Process(target = tm,name = ‘Tedu‘)
10 
11 p.daemon = True # 子进程会随父进程退出
12 
13 p.start()
14 print("Name:",p.name)  # 名称
15 print("PID:",p.pid)  # PID
16 print("Is alive:",p.is_alive()) # 生命周期

进程对象属性示例