一 Process对象的join方法
在主进程运行过程中如果想并发地执行其他的任务,我们可以开启子进程,此时主进程的任务与子进程的任务分两种情况
情况一:
在主进程的任务与子进程的任务彼此独立的情况下,主进程的任务先执行完毕后,主进程还需要等待子进程执行完毕,然后统一回收资源。 这种是没有join方法
情况二:
如果主进程的任务在执行到某一个阶段时,需要等待子进程执行完毕后才能继续执行,
就需要有一种机制能够让主进程检测子进程是否运行完毕,在子进程执行完毕后才继续执行,否则一直在原地阻塞,这就是join方法的作用
让主进程等着,所有子进程执行完毕后,主进程才继续执行
from multiprocessing import Process import time import os def task(): print("%s is running,parent id is <%s>" % (os.getpid(), os.getppid())) time.sleep(3) print("%s is done,parent id is <%s>" % (os.getpid(), os.getppid())) if __name__ == "__main__": t = Process(target=task, ) t.start() t.join() # 主进程 等子进程执行完了 print("主", os.getpid(), os.getppid()) ''' is running,parent id is <25956> is done,parent id is <25956> 主 25956 2992 '''
子进程运行完,最后打印主进程,主进程结束了 所有僵尸进程都会回收
开启多个字进程 向操作系统发送信号,但操作系统要处理的任务太多了,先开启 哪个子进程是随机的,有时候可能先开启主进程先,
操作系统什么时候开,开多长时间,我们是不知道的
from multiprocessing import Process import time import os def task(name): print('%s is running' %name) time.sleep(2) print('%s is end' %name) if __name__ == '__main__': p1 = Process(target=task, args=('子进程1',)) p2 = Process(target=task, args=('子进程2',)) p3 = Process(target=task, args=('子进程3',)) p4 = Process(target=task, args=('子进程4',)) p1.start() p2.start() p3.start() p4.start() print('主',os.getpid(),os.getppid()) ''' 子进程1 is running 子进程2 is running 主 9268 5236 子进程3 is running 子进程4 is running 子进程1 is end 子进程2 is end 子进程3 is end 子进程4 is end '''
也有可能这样,先开启主进程,
主 9556 5236 子进程1 is running 子进程3 is running 子进程2 is running 子进程4 is running 子进程1 is end 子进程3 is end 子进程2 is end 子进程4 is end
p.start() 只是给操作系统发送信号
join 会变串行?
既然join是等待进程结束, 那么我像下面这样写, 进程不就又变成串行的了吗"htmlcode">
from multiprocessing import Process import time import os def task(name): print('%s is running' %(name)) time.sleep(2) print('%s is end' %(name)) if __name__ == '__main__': p1 = Process(target=task, args=('子进程1',)) p2 = Process(target=task, args=('子进程2',)) p3 = Process(target=task, args=('子进程3',)) p4 = Process(target=task, args=('子进程4',)) p1.start() p2.start() p3.start() p4.start() p1.join() p2.join() p3.join() p4.join() print('主',os.getpid(),os.getppid())
详细解析如下:
进程只要start就会在开始运行了,所以p1-p4.start()时,系统中已经有四个并发的进程了
而我们p1.join()是在等p1结束,没错p1只要不结束主线程就会一直卡在原地,这也是问题的关键
join是让主线程等,而p1-p4仍然是并发执行的,p1.join的时候,其余p2,p3,p4仍然在运行,等#p1.join结束,可能p2,p3,p4早已经结束了,这样p2.join,p3.join.p4.join直接通过检测,无需等待
所以4个join花费的总时间仍然是耗费时间最长的那个进程运行的时间
所以不会是串行执行,是并发执行
4个join花费的总时间仍然是耗费时间最长的那个进程运行的时间
所以就是5秒,就是子进程1 那个等待的时间
from multiprocessing import Process import time import os def task(name,n): print('%s is running' %(name)) time.sleep(n) print('%s is end' %(name)) if __name__ == '__main__': start = time.time() p1 = Process(target=task, args=('子进程1',5)) p2 = Process(target=task, args=('子进程2',2)) p3 = Process(target=task, args=('子进程3',2)) p4 = Process(target=task, args=('子进程4',2)) p1.start() p2.start() p3.start() p4.start() p1.join() p2.join() p3.join() p4.join() print('主',time.time() - start) ''' 子进程1 is running 子进程2 is running 子进程3 is running 子进程4 is running 子进程2 is end 子进程3 is end 子进程4 is end 子进程1 is end 主 5.413309812545776 '''
这种方式就是串行
等子进程1执行时候,子进程2就没有发送信号,要等子进程1 执行完,再子进程2发送信号 ,开启子进程2再执行,按照这样的顺序
from multiprocessing import Process import time import os def task(name,n): print('%s is running' %(name)) time.sleep(n) print('%s is end' %(name)) if __name__ == '__main__': start = time.time() p1 = Process(target=task, args=('子进程1',5)) p2 = Process(target=task, args=('子进程2',2)) p3 = Process(target=task, args=('子进程3',2)) p4 = Process(target=task, args=('子进程4',2)) p1.start() p1.join() p2.start() p2.join() p3.start() p3.join() p4.start() p4.join() print('主',time.time() - start) ''' 子进程1 is running 子进程1 is end 子进程2 is running 子进程2 is end 子进程3 is running 子进程3 is end 子进程4 is running 子进程4 is end 主 12.212698698043823 '''
上述启动进程与 join进程 可以简写为以下
from multiprocessing import Process import time import os def task(name,n): print('%s is running' %(name)) time.sleep(n) print('%s is end' %(name)) if __name__ == '__main__': start = time.time() p1 = Process(target=task, args=('子进程1',5)) p2 = Process(target=task, args=('子进程2',2)) p3 = Process(target=task, args=('子进程3',2)) p4 = Process(target=task, args=('子进程4',2)) process_list = [p1,p2,p3,p4] for p in process_list: p.start() for p in process_list: p.join() print('主',time.time() - start)
join 保证所有子进程执行完 主进程才能工作,不然一直阻塞
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
《魔兽世界》大逃杀!60人新游玩模式《强袭风暴》3月21日上线
暴雪近日发布了《魔兽世界》10.2.6 更新内容,新游玩模式《强袭风暴》即将于3月21 日在亚服上线,届时玩家将前往阿拉希高地展开一场 60 人大逃杀对战。
艾泽拉斯的冒险者已经征服了艾泽拉斯的大地及遥远的彼岸。他们在对抗世界上最致命的敌人时展现出过人的手腕,并且成功阻止终结宇宙等级的威胁。当他们在为即将于《魔兽世界》资料片《地心之战》中来袭的萨拉塔斯势力做战斗准备时,他们还需要在熟悉的阿拉希高地面对一个全新的敌人──那就是彼此。在《巨龙崛起》10.2.6 更新的《强袭风暴》中,玩家将会进入一个全新的海盗主题大逃杀式限时活动,其中包含极高的风险和史诗级的奖励。
《强袭风暴》不是普通的战场,作为一个独立于主游戏之外的活动,玩家可以用大逃杀的风格来体验《魔兽世界》,不分职业、不分装备(除了你在赛局中捡到的),光是技巧和战略的强弱之分就能决定出谁才是能坚持到最后的赢家。本次活动将会开放单人和双人模式,玩家在加入海盗主题的预赛大厅区域前,可以从强袭风暴角色画面新增好友。游玩游戏将可以累计名望轨迹,《巨龙崛起》和《魔兽世界:巫妖王之怒 经典版》的玩家都可以获得奖励。
更新日志
- 群星《前途海量 电影原声专辑》[FLAC/分轨][227.78MB]
- 张信哲.1992-知道新曲与精丫巨石】【WAV+CUE】
- 王翠玲.1995-ANGEL【新艺宝】【WAV+CUE】
- 景冈山.1996-我的眼里只有你【大地唱片】【WAV+CUE】
- 群星《八戒 电影原声带》[320K/MP3][188.97MB]
- 群星《我的阿勒泰 影视原声带》[320K/MP3][139.47MB]
- 纪钧瀚《胎教古典音乐 钢琴与大提琴的沉浸时光》[320K/MP3][148.91MB]
- 刘雅丽.2001-丽花皇后·EMI精选王【EMI百代】【FLAC分轨】
- 齐秦.1994-黄金十年1981-1990CHINA.TOUR.LIVE精丫上华】【WAV+CUE】
- 群星.2008-本色·百代音乐人创作专辑【EMI百代】【WAV+CUE】
- 群星.2001-同步过冬AVCD【环球】【WAV+CUE】
- 群星.2020-同步过冬2020冀待晴空【环球】【WAV+CUE】
- 沈雁.1986-四季(2012梦田复刻版)【白云唱片】【WAV+CUE】
- 纪钧瀚《胎教古典音乐 钢琴与大提琴的沉浸时光》[FLAC/分轨][257.88MB]
- 《国语老歌 怀旧篇 3CD》[WAV/分轨][1.6GB]