python 多线程中join()的作用

一前言

温习python 多进程语法的时候，对 join的理解不是很透彻，本文通过代码实践来加深对 join()的认识。

multiprocessing 是python提供的跨平台版本的多进程模块。multiprocessing可以充分利用多核，提升程序运行效率。multiprocessing支持子进程,通信和共享数据,执行不同形式的同步,提供了Process、Queue、Pipe、Lock等组件。不过今天重点了解 join。后续文章会逐步学习介绍其他组件或者功能。

二动手实践

join()方法可以在当前位置阻塞主进程，带执行join()的进程结束后再继续执行主进程的代码逻辑。

# encoding: utf-8
\"\"\"
author: yangyi@youzan.com
time: 2019/7/30 11:20 AM
func:
\"\"\"

from multiprocessing import Process
import os
import time

def now():
  return str(time.strftime(\'%Y-%m-%d %H:%M:%S\', time.localtime()))


def func_1(name):
  print(now() + \' Run child process %s (%s)...\' % (name, os.getpid()))
  time.sleep(4)
  print(now() + \' Stop child process %s (%s)...\\n\' % (name, os.getpid()))


def func_2(name):
  print(now() + \' Run child process %s (%s)...\' % (name, os.getpid()))
  time.sleep(8)
  print(now() + \' hello world!\')
  print(now() + \' Stop child process %s (%s)...\\n\' % (name, os.getpid()))


if __name__ == \'__main__\':
  print (\'Parent process %s.\' % os.getpid())
  p1 = Process(target=func_1, args=(\'func_1\',))
  p2 = Process(target=func_2, args=(\'func_2\',))
  print now() + \' Process start.\'
  p1.start()
  p2.start()
  p1.join()
  p2.join()
  print now() + \' Process end .\'

输出结果

python 多线程中join()的作用

结果显示

主进程的 Process end .是在func1 和func2 结束之后才打印出来的。

2.2 去掉 join() 函数

if __name__ == \'__main__\':
  print (\'Parent process %s.\' % os.getpid())
  p1 = Process(target=func_1, args=(\'func_1\',))
  p2 = Process(target=func_2, args=(\'func_2\',))
  print now() + \' Process start.\'
  p1.start()
  p2.start()
  print now() + \' Process end .\'

结果如下:

python 多线程中join()的作用

2.3 去掉func_2 的 join()

if __name__ == \'__main__\':
  print (\'Parent process %s.\' % os.getpid())
  p1 = Process(target=func_1, args=(\'func_1\',))
  p2 = Process(target=func_2, args=(\'func_2\',))
  print now() + \' Process start.\'
  p1.start()
  p2.start()
  p1.join() ### 在p1 执行完之后 。不等待p2 执行，主进程结束。
  print now() + \' Process end .\'

结果如下:

python 多线程中join()的作用