python中的多进程的创建与启动方式
(相关资料图)
目录
一、多进程的创建:多进程的创建方法有两种:1、通过Process创建多进程 Process语法结构:2、通过进程池创建并启动多进程3、通过继承的方法创建多进程4、进程创建与启动完整代码python中的并发有三种形式,多进程、多线程、协程。执⾏并发任务的⽬的是为了提⾼程序运⾏的效率。
一、多进程的创建:多进程的创建方法有两种:
1、通过Process创建多进程 Process语法结构:
Process(group, target, name, args, kwargs) group:指定进程组,⼤多数情况下⽤不到 target:表示调用对象,即子进程要执行的任务 name:子进程的名称,可以不设定 args:给target指定的函数传递的参数,以元组的⽅式传递 kwargs:给target指定的函数传递命名参数
Process常用方法:
p.start() 启动进程,并调用该子进程中的p.run()方法 p.join(timeout):主进程等待⼦进程执⾏结束再结束,timeout是可选的超时时间 is_alive():判断进程⼦进程是否还存活 p.run() 进程启动时运行的方法,正是它去调用target指定的函数 p.terminate() ⽴即终⽌⼦进程
(1)首先,定义一个待调用的函数:
import os from multiprocessing import Process def add(name,num): nums = 0 for i in range(num+1): nums = nums+i print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"%(name,nums,os.getpid(),os.getppid()))
(2)创建并启动一个进程
def test1(): """启动一个进程调用""" name= "王五" p = Process(target=add,args=(name,10,)) p.start() p.join()
其中,p.join()方法可以让主进程等待子进程结束之后再结束,如果不加这个方法,主进程结束,子进程还没有结束。
(2)创建并启动多个进程
def test3(): names = ["王五","赵六","王麻子"] process_list=[] for name in names: p = Process(target=add,args=(name,10,)) p.start() process_list.append(p) for j in process_list: j.join()
2、通过进程池创建并启动多进程
进程池可以提供指定数量的进程给用户使用,即当有新的请求提交到进程池中时,如果池未满,则会创建一个新的进程用来执行该请求;反之,如果池中的进程数已经达到规定最大值,那么该请求就会等待,只要池中有进程空闲下来,该请求就能得到执行。
Pool(numprocess, initializer, initargs)
numprocess 是要创建的进程数。如果省略此参数,默认为cpu的最大核心数。
Initializer是每个工作进程启动时要执行的可调用对象。
Initargs 传递给 initializer 的参数元祖,默认为 None
def test4(): from multiprocessing import Pool """启动多个进程2:进程池""" p = Pool(5) names = ["王五","赵六","王麻子"] for name in names: p.apply_async(add,args=(name,10)) p.close() p.join()
3、通过继承的方法创建多进程
(1)首先创建一个进程
class SubProcess(Process): def __init__(self,name,number): super(SubProcess, self).__init__() self.name = name self.number = number def run(self): sums = 0 for i in range(self.number): sums = sums+i print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"\ %(self.name,self.number,os.getpid(),os.getppid()))
(2)启动一个进程
def call_Sub0(): """启动一个进程调用""" name = "张三" p = SubProcess(name,10) p.start() p.join()
(3)通过列表启动多个进程
def call_Sub1(): """启动多个进程1""" names = ["王五","赵六","王麻子"] process_list=[] for name in names: p = SubProcess(name,10) p.start() process_list.append(p) for j in process_list: j.join() if __name__ == "__main__": print("当前主进程id:",os.getpid()) call_Sub1() print("计算结束!")
4、进程创建与启动完整代码
import os from multiprocessing import Process def add(name,num): nums = 0 for i in range(num+1): nums = nums+i print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"%(name,nums,os.getpid(),os.getppid())) def test1(): """启动一个进程调用""" name= "王五" p = Process(target=add,args=(name,10,)) p.start() p.join() def test3(): """启动多个进程2""" names = ["王五","赵六","王麻子"] process_list=[] for name in names: p = Process(target=add,args=(name,10,)) p.start() process_list.append(p) for j in process_list: j.join() """ 进程池:可以提供指定数量的进程给用户使用,即当有新的请求提交到进程池中时, 如果池未满,则会创建一个新的进程用来执行该请求;反之,如果池中的进程数已经达到规定最大值, 那么该请求就会等待,只要池中有进程空闲下来,该请求就能得到执行。 """ def test4(): from multiprocessing import Pool """启动多个进程2:进程池""" p = Pool(5) names = ["王五","赵六","王麻子"] for name in names: p.apply_async(add,args=(name,10)) p.close() p.join() class SubProcess(Process): def __init__(self,name,number): super(SubProcess, self).__init__() self.name = name self.number = number def run(self): sums = 0 for i in range(self.number): sums = sums+i print("用户%s:\n 相加结果为:%s \n 当前进程id为:%s \n 当前子进程的父进程id: %s"\ %(self.name,self.number,os.getpid(),os.getppid())) def call_Sub0(): """启动一个进程调用""" name = "张三" p = SubProcess(name,10) p.start() p.join() def call_Sub1(): """启动多个进程1""" names = ["王五","赵六","王麻子"] process_list=[] for name in names: p = SubProcess(name,10) p.start() process_list.append(p) for j in process_list: j.join() if __name__ == "__main__": print("当前主进程id:",os.getpid()) call_Sub1() print("计算结束!")
到此这篇关于python中的多进程的创建与启动的文章就介绍到这了,更多相关python多进程创建与启动内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
X 关闭
X 关闭
- 15G资费不大降!三大运营商谁提供的5G网速最快?中国信通院给出答案
- 2联想拯救者Y70发布最新预告:售价2970元起 迄今最便宜的骁龙8+旗舰
- 3亚马逊开始大规模推广掌纹支付技术 顾客可使用“挥手付”结账
- 4现代和起亚上半年出口20万辆新能源汽车同比增长30.6%
- 5如何让居民5分钟使用到各种设施?沙特“线性城市”来了
- 6AMD实现连续8个季度的增长 季度营收首次突破60亿美元利润更是翻倍
- 7转转集团发布2022年二季度手机行情报告:二手市场“飘香”
- 8充电宝100Wh等于多少毫安?铁路旅客禁止、限制携带和托运物品目录
- 9好消息!京东与腾讯续签三年战略合作协议 加强技术创新与供应链服务
- 10名创优品拟通过香港IPO全球发售4100万股 全球发售所得款项有什么用处?