一个正在运行的程序或者软件就是一个进程,它是 *** 作系统进行资源分配的基本单位,也就是说每启动一个进程, *** 作系统都会给其分配一定的运行资源(内存资源)保证进程的运行。
比如:现实生活中的公司可以理解成是一个进程,公司提供办公资源(电脑、办公桌椅等),真正干活的是员工,员工可以理解成线程。
注意:
一个程序运行后至少有一个进程,一个进程默认有一个线程,进程里面可以创建多个线程,线程是依附在进程里面的,没有进程就没有线程。
进程的作用单进程效果图:
多进程效果图:
说明:
多进程可以完成多任务,每个进程就好比一家独立的公司,每个公司都各自在运营,每个进程也各自在运行,执行各自的任务。
多进程的使用导入进程包#导入进程包import multiprocessingProcess进程类的说明
Process([group [,target [,name [,args [,kwargs]]]]])
group:指定进程组,目前只能使用Nonetarget:执行的目标任务名name:进程名字args:以元组方式给执行任务传参kwargs:以字典方式给执行任务传参Process创建的实例对象的常用方法:
start():启动子进程实例(创建子进程)join():等待子进程执行结束terminate():不管任务是否完成,立即终止子进程Process创建的实例对象的常用属性:
name:当前进程的别名,默认为Process-N,N为从1开始递增的整数多进程完成多任务的代码import multiprocessing time 跳舞任务def dance(): for i in range(5): print("跳舞中...") time.sleep(0.2) 唱歌任务 sing(): 唱歌中...)if __name__ == '__main__': 创建跳舞的子进程 group: 表示进程组,目前只能使用None target: 表示执行的目标任务名(函数名、方法名) name: 进程名称,默认是Process-1,..... dance_process = multiprocessing.Process(target=dance,name=myprocess1) sing_process = multiprocessing.Process(target=sing) 启动子进程执行对应的任务 dance_process.start() sing_process.start()获取进程编号的目的
获取进程编号的目的是验证主进程和子进程的关系,可以得知子进程是由那个主进程创建出来的。
获取进程编号的两种 *** 作
获取当前进程编号获取当前父进程编号获取当前进程编号os.getpID() 表示获取当前进程编号
示例代码:
time os 获取当前进程的编号 dance:,os.getpID()) 获取当前进程 ) 扩展:根据进程编号杀死指定进程 os.kill(os.getpID(),9sing:: main: dance_process.start() sing_process.start()获取当前父进程编号
os.getppID() 表示获取当前父进程编号
示例代码:
获取父进程的编号 dance的父进程编号:sing的父进程编号: dance_process.start() sing_process.start()进程执行带有参数的任务的介绍
前面我们使用进程执行的任务是没有参数的,假如我们使用进程执行的任务带有参数,如何给函数传参呢?
Process类执行任务并给任务传参数有两种方式:
args 表示以元组的方式给执行任务传参kwargs 表示以字典方式给执行任务传参args参数的使用示例代码:
带有参数的任务 task(count): in range(count): 任务执行中..) else: 任务执行完成 创建子进程 args: 以元组的方式给任务传入参数 sub_process = multiprocessing.Process(target=task,args=(5 创建子进程 kwargs: 表示以字典方式传入参数 sub_process = multiprocessing.Process(target=task,kwargs={count": 3}) sub_process.start()进程的注意点进程的注意点介绍进程之间不共享全局变量主进程会等待所有的子进程执行结束再结束进程之间不共享全局变量
time 定义全局变量g_List = List() 添加数据的任务 add_data(): ): g_List.append(i) add:) 代码执行到此,说明数据添加完成 add_data: read_data(): read_data 创建添加数据的子进程 add_data_process = multiprocessing.Process(target=add_data) 创建读取数据的子进程 read_data_process = multiprocessing.Process(target=read_data) add_data_process.start() 主进程等待添加数据的子进程执行完成以后程序再继续往下执行,读取数据 add_data_process.join() read_data_process.start() 总结: 多进程之间不共享全局变量
进程之间不共享全局变量的解释效果图:
创建子进程会对主进程资源进行拷贝,也就是说子进程是主进程的一个副本,好比是一对双胞胎,之所以进程之间不共享全局变量,是因为 *** 作的不是同一个进程里面的全局变量,只不过不同进程里面的全局变量名字相同而已。主进程会等待所有的子进程执行结束再结束
假如我们现在创建一个子进程,这个子进程执行完大概需要2秒钟,现在让主进程执行0.5秒钟就退出程序,查看一下执行结果,示例代码如下:
定义进程所需要执行的任务 task(): in range(10任务执行中... 创建子进程 sub_process = multiprocessing.Process(target=task) sub_process.start() 主进程延时0.5秒钟 time.sleep(0.5over) exit() 总结: 主进程会等待所有的子进程执行完成以后程序再退出
通过上面代码的执行结果,我们可以得知: 主进程会等待所有的子进程执行结束再结束
假如我们就让主进程执行0.5秒钟,子进程就销毁不再执行,那怎么办呢?
我们可以设置守护主进程 或者 在主进程退出之前 让子进程销毁守护主进程:
守护主进程就是主进程退出子进程销毁不再执行子进程销毁:
子进程执行结束task) 设置守护主进程,主进程退出子进程直接销毁,子进程的生命周期依赖与主进程 sub_process.daemon = True sub_process.start() time.sleep(0.5 让子进程销毁 sub_process.terminate() exit() 总结: 主进程会等待所有的子进程执行完成以后程序再退出 如果想要主进程退出子进程销毁,可以设置守护主进程或者在主进程退出之前让子进程销毁为了保证子进程能够正常的运行,主进程会等所有的子进程执行完成以后再销毁,设置守护主进程的目的是主进程退出子进程销毁,不让主进程再等待子进程去执行。设置守护主进程方式: 子进程对象.daemon = True销毁子进程方式: 子进程对象.terminate() 总结
以上是内存溢出为你收集整理的Python--进程全部内容,希望文章能够帮你解决Python--进程所遇到的程序开发问题。
如果觉得内存溢出网站内容还不错,欢迎将内存溢出网站推荐给程序员好友。
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)