python 多进程 multiprocessing模块教程

开启一个子进程函数,子进程函数不带参数

from multiprocessing import Process

def func_01():
    print('子进程')

if __name__ == '__main__':  # 开启多进程 必修有此行代码

    # target=要开启的子进程的函数 
    p = Process(target=func_01)  # 实例化一个进程对象
    p.start()  # 开启一个子进程
    print('父进程')

• • • • • -

开启一个子进程函数,子进程函数带参数

from multiprocessing import Process

def func_01(a):
    print('子进程')

if __name__ == '__main__':  # 开启多进程 必修有此行代码

    # target=开启这个子进程的函数 args=要传给这个子进程函数的参数 必须为元组类型 本示例随意传递了参数
    p = Process(target=func_01, args=(123,))  # 实例化一个进程对象
    p.start()  # 开启一个子进程
    print('父进程')

• • • • • -

子进程与父进程同时运行,可通过如下的间隔打印示例看出,其打印结果为"子进程"与"父进程"交替出现,代表子进程与父进程同时运行(多进程)

from multiprocessing import Process
import time

def func_01(a):
    for i in range(1, 10, 1):
        time.sleep(0.1)
        print('子进程')

if __name__ == '__main__':  # 开启多进程 必修有此行代码

    # target=开启这个子进程的函数 args=要传给这个子进程函数的参数 必须为元组类型 本示例随意传递了参数
    p = Process(target=func_01, args=(123,))  # 实例化一个进程对象
    p.start()  # 开启一个子进程
    for i in range(1, 10, 1):
        print('父进程')
        time.sleep(0.1)

• • • • • -

正常情况下 主进程与子进程一同运行.
当使用join() 时,主进程将阻塞住并等待子进程执行完再继续运行下面的代码
如下的代码示例将先打印完全部"子进程",再打印"父进程",而不是交替打印.

from multiprocessing import Process
import time

def func_001():
    for i in range(1, 50, 1):
        time.sleep(0.05)
        print('子进程')

if __name__ == '__main__':  # 开启多进程 必修有此行代码
    p = Process(target=func_001)
    p.start()  # 开启一个子进程
    p.join()  # join() 主进程将阻塞住并等待子进程执行完再继续运行下面的代码
    for i in range(1, 50, 1):
        time.sleep(0.05)
        print('父进程')

• • • • • -

os.getpid() 返回当前进程的pid
os.getppid() 返回当前进程的父进程的pid

from multiprocessing import Process
import os

def func_01():
    print('子进程的pid:', os.getpid(), '我的父进程的pid', os.getppid())

if __name__ == '__main__':  # 开启多进程 必修有此行代码

    # target=要开启的子进程的函数
    p = Process(target=func_01)  # 实例化一个进程对象
    p.start()  # 开启一个子进程
    print('父进程的pid:', os.getpid())

pid可在任务管理器的’进程’中查看,如果没有显示可以通过任务管理器中的相关设置来显示进程的pid

• • • • • -

p = Process(target=func\_01, name=‘进程01’) 中的
name参数命名一个进程的名字.

p.name方法查看进程的名字

from multiprocessing import Process

def func_01():
    print('子进程')

if __name__ == '__main__':  # 开启多进程 必修有此行代码

    # target=要开启的子进程的函数  name=进程的名字
    p = Process(target=func_01, name='进程01')  # 实例化一个进程对象
    p.start()  # 开启一个子进程
    print('父进程')
    print('进程的名字:', p.name)  # 打印进程的名字

• • • • • -

.is\_alive() 判断进程是否存活 返回布尔型数据
本示例中,子进程运行2秒,父进程运行5秒,第一次判断存活为True,第二次判断存活在5秒后为False.

from multiprocessing import Process
import time

def func_01():
    print('子进程')
    time.sleep(2)

if __name__ == '__main__':  # 开启多进程 必修有此行代码

    # target=要开启的子进程的函数  name=进程的名字
    p01 = Process(target=func_01, name='进程01')  # 实例化一个进程对象
    p01.start()  # 开启一个子进程
    print('子进程func_01是否存活:', p01.is_alive())  # 判断进程是否存活 返回布尔型数据
    time.sleep(5)
    print('子进程func_01是否存活:', p01.is_alive())

• • • • • -

.terminate() 杀死进程

from multiprocessing import Process
import time

def func_01():
    time.sleep(200)  # 子进程运行200秒

if __name__ == '__main__':  # 开启多进程 必修有此行代码

    # target=要开启的子进程的函数  name=进程的名字
    p01 = Process(target=func_01, name='进程01')  # 实例化一个进程对象
    p01.start()  # 开启一个子进程
    print('子进程func_01是否存活:', p01.is_alive())  # 判断进程是否存活
    p01.terminate()  # 手动杀死子进程
    time.sleep(1)  # 给计算机杀死进程的工作时间
    print('子进程func_01是否存活:', p01.is_alive())  # 判断进程是否存活

• • • • • -

.daemon = True 守护进程
守护进程(子进程)会在父进程的代码执行结束后一同结束.
如下的示例,普通情况下’子进程func\_01’会在运行完100秒之后才结束,而将其设置为守护进程后(p01.daemon = True ),他会在父进程结束后一同结束.
而且守护进程不可以再拥有属于自己的子进程,

from multiprocessing import Process
import time

def func_01():
    time.sleep(100)
    print('子进程')

if __name__ == '__main__':
    p01 = Process(target=func_01)
    p01.daemon = True  # 将p进程设置为守护进程 在start之前设置
    p01.start()
    time.sleep(1)
    print('父进程')