python并发编程 Process对象的其他属性方法join方法详解

更新时间：2019年08月20日 14:10:42 作者：minger_lcm

这篇文章主要介绍了python并发编程 Process对象的其他属性方法join方法详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下

一 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是等待进程结束, 那么我像下面这样写, 进程不就又变成串行的了吗?
当然不是了, 必须明确：p.join()是让谁等？
很明显p.join()是让主线程等待p 子进程的结束，卡住的是主进程而绝非子进程p，

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 保证所有子进程执行完主进程才能工作，不然一直阻塞

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

python 爬取天气网卫星图片
根据网站URL的规律编写的一个爬取天气网卫星图片的python爬虫，使用了requests包，感兴趣的朋友可以参考下
2021-06-06
PyQt5+QtChart实现柱状图的绘制
QChart是一个QGraphicScene中可以显示的QGraphicsWidget。本文将利用QtChart实现柱状图的绘制，文中的示例代码讲解详细，感兴趣的小伙伴可以了解一下
2022-12-12
手把手教你如何用Pycharm2020.1.1配置远程连接的详细步骤
这篇文章主要介绍了如何用Pycharm2020.1.1配置远程连接，分步骤给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友参考下吧
2020-08-08
Python实现的栈、队列、文件目录遍历操作示例
这篇文章主要介绍了Python实现的栈、队列、文件目录遍历操作,结合实例形式分析了Python数据结构中栈与队列的定义、使用,以及文件目录的遍历相关操作技巧,需要的朋友可以参考下
2019-05-05
Python魔法方法功能与用法简介
这篇文章主要介绍了Python魔法方法功能与用法,结合具体实例形式分析了Python面向对象程序设计中魔法方法的概念、功能、原理、用法及相关操作注意事项,需要的朋友可以参考下
2019-04-04
Python实现捕获异常发生的文件和具体行数
这篇文章主要介绍了Python实现捕获异常发生的文件和具体行数。具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-04-04
Python设计模式之模板方法模式实例详解
这篇文章主要介绍了Python设计模式之模板方法模式,结合实例形式较为详细的分析了模板方法模式的概念、原理及Python定义、使用模板方法模式相关操作技巧,需要的朋友可以参考下
2019-01-01
Python实现一个简单的毕业生信息管理系统的示例代码
这篇文章主要介绍了Python实现一个简单的毕业生信息管理系统的示例代码，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-06-06
在python中解决死锁的问题
这篇文章主要介绍了在python中解决死锁的问题，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2021-04-04
基于keras输出中间层结果的2种实现方式
今天小编就为大家分享一篇基于keras输出中间层结果的2种实现方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-01-01

python并发编程 Process对象的其他属性方法join方法详解

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具