python并发编程 Process对象的其他属性方法join方法详解
一Process对象的join方法
在主进程运行过程中如果想并发地执行其他的任务,我们可以开启子进程,此时主进程的任务与子进程的任务分两种情况
情况一:
在主进程的任务与子进程的任务彼此独立的情况下,主进程的任务先执行完毕后,主进程还需要等待子进程执行完毕,然后统一回收资源。这种是没有join方法
情况二:
如果主进程的任务在执行到某一个阶段时,需要等待子进程执行完毕后才能继续执行,
就需要有一种机制能够让主进程检测子进程是否运行完毕,在子进程执行完毕后才继续执行,否则一直在原地阻塞,这就是join方法的作用
让主进程等着,所有子进程执行完毕后,主进程才继续执行
frommultiprocessingimportProcess importtime importos deftask(): print("%sisrunning,parentidis<%s>"%(os.getpid(),os.getppid())) time.sleep(3) print("%sisdone,parentidis<%s>"%(os.getpid(),os.getppid())) if__name__=="__main__": t=Process(target=task,) t.start() t.join() #主进程等子进程执行完了 print("主",os.getpid(),os.getppid()) ''' isrunning,parentidis<25956> isdone,parentidis<25956> 主259562992 '''
子进程运行完,最后打印主进程,主进程结束了所有僵尸进程都会回收
开启多个字进程向操作系统发送信号,但操作系统要处理的任务太多了,先开启哪个子进程是随机的,有时候可能先开启主进程先,
操作系统什么时候开,开多长时间,我们是不知道的
frommultiprocessingimportProcess importtime importos deftask(name): print('%sisrunning'%name) time.sleep(2) print('%sisend'%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()) ''' 子进程1isrunning 子进程2isrunning 主92685236 子进程3isrunning 子进程4isrunning 子进程1isend 子进程2isend 子进程3isend 子进程4isend '''
也有可能这样,先开启主进程,
主95565236 子进程1isrunning 子进程3isrunning 子进程2isrunning 子进程4isrunning 子进程1isend 子进程3isend 子进程2isend 子进程4isend
p.start()只是给操作系统发送信号
join会变串行?
既然join是等待进程结束,那么我像下面这样写,进程不就又变成串行的了吗?
当然不是了,必须明确:p.join()是让谁等?
很明显p.join()是让主线程等待p子进程的结束,卡住的是主进程而绝非子进程p,
frommultiprocessingimportProcess importtime importos deftask(name): print('%sisrunning'%(name)) time.sleep(2) print('%sisend'%(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那个等待的时间
frommultiprocessingimportProcess importtime importos deftask(name,n): print('%sisrunning'%(name)) time.sleep(n) print('%sisend'%(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) ''' 子进程1isrunning 子进程2isrunning 子进程3isrunning 子进程4isrunning 子进程2isend 子进程3isend 子进程4isend 子进程1isend 主5.413309812545776 '''
这种方式就是串行
等子进程1执行时候,子进程2就没有发送信号,要等子进程1执行完,再子进程2发送信号,开启子进程2再执行,按照这样的顺序
frommultiprocessingimportProcess importtime importos deftask(name,n): print('%sisrunning'%(name)) time.sleep(n) print('%sisend'%(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) ''' 子进程1isrunning 子进程1isend 子进程2isrunning 子进程2isend 子进程3isrunning 子进程3isend 子进程4isrunning 子进程4isend 主12.212698698043823 '''
上述启动进程与join进程可以简写为以下
frommultiprocessingimportProcess importtime importos deftask(name,n): print('%sisrunning'%(name)) time.sleep(n) print('%sisend'%(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] forpinprocess_list: p.start() forpinprocess_list: p.join() print('主',time.time()-start)
join保证所有子进程执行完主进程才能工作,不然一直阻塞
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持毛票票。