第二十一天Python之进程

多任务

电脑中的多任务

思考：为什么在下载的时候要多个任务同时下载

多任务的优势
多任务的最大好处是充分 利用CPU资源，提高程序的执行效率

1. 多任务的概念
多任务是指在 同一时间 内执行 多个任务

2. 多任务的两种表现形式

并发
并行

3. 并发
在一段时间内交替去执行多个任务

例子：
对于单核cpu处理多任务，操作系统轮流让各个 任务交替执行

4. 并行
在一段时间内 真正的同时一起 执行多个任务

例子：
对于多核cpu处理多任务，操作系统会给cpu的每个内核安排一个执行的任务，多个内核是真正的 一起同时执行多个任务。 这里需要注意多核cpu是并行的执行多任务，始终有多个任务一起执行。

进程的介绍

1. 程序中实现多任务的方式
在 Python 中，想要实现多任务可以使用 多进程 来完成

2. 进程的概念
进程（Process）是资源分配的最小单位，它是操作系统进行资源分配和调度运行的基本单位，通俗理解：一个正在运行的程序就是一个进程，例如：正在运行的qq，微信等，他们都是一个进程

注意：

一个程序运行后至少有一个进程

3. 多进程的作用

思考
图中是一个非常简单的程序，一旦运行hello.py这个程序，按照代码的执行顺序，func_a函数执行完毕后才能执行func_b函数，如果可以让func_a和func_b同时运行，显然执行hello.py这个程序的效率会大大提升

4. 多进程的作用

多进程完成多任务

1. 进程的创建步骤

导入进程包

import multiprocessing

通过进程类创建进程对象

进程对象 = multiprocessing.Process()

启动进程执行任务

进程对象.start()

2. 通过进程类创建进程对象

进程对象 = multiprocessing.Process(target=任务名)

参数名	说明
target	执行的目标任务名，这里指的是函数名(方法名)
name	进程名，一般不同设置
group	进程组，目前只能使用None

3. 进程创建与启动的代码

# 创建子进程
sing_process = multiprocessing.Process(target=sing)
# 创建子进程
dance_process = multiprocessing.Process(target=dance)
# 启动进程
sing_process.start()
dance_process.start()

多进程完成多任务

导入进程包 import multiprocessing
创建子进程并指定执行的任务 sub_process = multiprocessing.Process(target=任务名)

进程执行带有参数的任务

1. 进程执行带有参数的任务

参数名	说明
args	以元组的方式给执行任务传参
kwargs	以字典方式给执行任务传参

2. args参数的使用

# target：进程执行的函数名
# args：表示以元组的方式给函数传参
sing_process = multiprocessing.Process(target=sing,args=(3,))
sing_process.start()

3. kwargs参数的使用

# target：进程执行的函数名
# kwargs：表示以字典的方式给函数传参
dance_process = multiprocessing.Process(target=dance, kwargs={"num":3})
# 启动进程
dance_process.start()

进程执行带有参数的任务

元组方式传参： 元组方式传参一定要和参数的 顺序保持一致
字典方式传参： 字典方式传参字典中的Key一定要和 参数名保持一致

获取进程编号

进程编号的作用
当程序中进程的数量越来越多时，如果没有办法区分朱金城和子进程还有不同的子进程，那么就无法进行有效的进程管理，为了方便管理实际上每个进程都是有自己编号的

获取进程编号的两种方式：

获取当前进程编号
os.getpid()
获取当前父进程编号
os.getppid()

1. os.getpid()的使用

import os
pid = os.getpid()
print(pid)

2. os.getppid()的使用

def work():# 获取当前进程的编号print("work进程编号", os.getpid())# 获取父进程的编号print(“work父进程的编号”, os.getppid())

获取进程编号

获取当前进程编号：os.getpid()
获取当前父进程编号：os.getppid()

进程的注意点

主进程会等待所有的子进程执行结束再结束

1. 主进程会等待所有的子进程执行结束再结束

import time
import multiprocessingdef work():for i in range(10):print("工作中...")time.sleep(0.2)if __name__ == '__main__':work_process = multiprocessing.Process(target=work)work_process.start()# 主进程睡眠1秒time.sleep(1)print("主进程执行完了")

2. 设置守护主进程

import time
import multiprocessingdef work():for i in range(10):print("工作中...")time.sleep(0.2)if __name__ == '__main__':work_process = multiprocessing.Process(target=work)# 设置守护主进程，主进程结束子进程自动销毁，不再执行子进程代码work_process.daemon = Truework_process.start()# 主进程睡眠1秒time.sleep(1)print("主进程执行完了")

3. 知识要点

为了保证子进程能够正常的运行，主进程会等所有的子进程执行完成以后再销毁，设置守护主进程的目的是主进程退出子进程销毁，不让主进程再等待子进程去执行。

设置守护主进程方式：子进程对象.daemon = True

进程的注意点

主进程会等待所有的子进程执行结束再结束，除非设置子进程守护主进程