概述
多任务
电脑中的多任务
思考:为什么在下载的时候要多个任务同时下载
多任务的优势
多任务的最大好处是充分 利用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 multiprocessing
def 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 multiprocessing
def work():
for i in range(10):
print("工作中...")
time.sleep(0.2)
if __name__ == '__main__':
work_process = multiprocessing.Process(target=work)
# 设置守护主进程,主进程结束子进程自动销毁,不再执行子进程代码
work_process.daemon = True
work_process.start()
# 主进程睡眠1秒
time.sleep(1)
print("主进程执行完了")
3. 知识要点
为了保证子进程能够正常的运行,主进程会等所有的子进程执行完成以后再销毁,设置守护主进程的目的是主进程退出子进程销毁,不让主进程再等待子进程去执行。
设置守护主进程方式:子进程对象.daemon = True
进程的注意点
- 主进程会等待所有的子进程执行结束再结束,除非设置子进程守护主进程
最后
以上就是清爽睫毛为你收集整理的第二十一天Python之进程的全部内容,希望文章能够帮你解决第二十一天Python之进程所遇到的程序开发问题。
如果觉得靠谱客网站的内容还不错,欢迎将靠谱客网站推荐给程序员好友。
发表评论 取消回复