快捷導(dǎo)航

python 多線程中join()的作用

更新時(shí)間：2020年10月29日 10:48:54 作者：用戶1278550

這篇文章主要介紹了python 多線程中join()的作用，通過(guò)代碼實(shí)踐來(lái)加深對(duì) join()的認(rèn)識(shí)，幫助大家更好的理解和學(xué)習(xí)python 多線程，感興趣的朋友可以了解下

一前言

溫習(xí)python 多進(jìn)程語(yǔ)法的時(shí)候，對(duì) join的理解不是很透徹，本文通過(guò)代碼實(shí)踐來(lái)加深對(duì) join()的認(rèn)識(shí)。

multiprocessing 是python提供的跨平臺(tái)版本的多進(jìn)程模塊。multiprocessing可以充分利用多核，提升程序運(yùn)行效率。multiprocessing支持子進(jìn)程,通信和共享數(shù)據(jù),執(zhí)行不同形式的同步,提供了Process、Queue、Pipe、Lock等組件。不過(guò)今天重點(diǎn)了解 join。后續(xù)文章會(huì)逐步學(xué)習(xí)介紹其他組件或者功能。

二動(dòng)手實(shí)踐

join()方法可以在當(dāng)前位置阻塞主進(jìn)程，帶執(zhí)行join()的進(jìn)程結(jié)束后再繼續(xù)執(zhí)行主進(jìn)程的代碼邏輯。

# 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 .'

輸出結(jié)果

結(jié)果顯示

主進(jìn)程的 Process end .是在func1 和func2 結(jié)束之后才打印出來(lái)的。

2.2 去掉 join() 函數(shù)

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 .'

結(jié)果如下:

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 執(zhí)行完之后 。不等待p2 執(zhí)行，主進(jìn)程結(jié)束。
  print now() + ' Process end .'

結(jié)果如下: