Python多线程中join()函数如何实现线程同步?

2026-05-05 10:351阅读0评论SEO资讯
  • 内容介绍
  • 文章标签
  • 相关推荐

本文共计742个文字,预计阅读时间需要3分钟。

Python多线程中join()函数如何实现线程同步?

一、前言:温习Python多进程语法的时间,对join()的理解不是非常透彻,通过代码实践来加深对join()的认识。

+multiprocessing是Python提供的跨平台的多进程模块。

+multiprocessing模块可以充分利用多核CPU的计算能力,实现多进程。它可以创建多个进程,并允许这些进程共享内存,从而提高程序的执行效率。

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

输出结果

结果显示

主进程的 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 .'

结果如下:

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

结果如下:

结果显示主线程 "Process end"在func_1 执行结束之后输出而没有等待func_2 执行完毕。

2.4 小结

利用多线程时,一般都先让子线程调用start() ,然后再去调用join(),让主进程等待子进程结束才继续走后续的逻辑。

思考题

能不能每个子进程调用start() 之后,然后直接调用join() 类似:

p1.start()p1.join()p2.start()p2.join()

以上就是python 多线程中join()的作用的详细内容,更多关于python 多线程join()的资料请关注易盾网络其它相关文章!

本文共计742个文字,预计阅读时间需要3分钟。

Python多线程中join()函数如何实现线程同步?

一、前言:温习Python多进程语法的时间,对join()的理解不是非常透彻,通过代码实践来加深对join()的认识。

+multiprocessing是Python提供的跨平台的多进程模块。

+multiprocessing模块可以充分利用多核CPU的计算能力,实现多进程。它可以创建多个进程,并允许这些进程共享内存,从而提高程序的执行效率。

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

输出结果

结果显示

主进程的 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 .'

结果如下:

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

结果如下:

结果显示主线程 "Process end"在func_1 执行结束之后输出而没有等待func_2 执行完毕。

2.4 小结

利用多线程时,一般都先让子线程调用start() ,然后再去调用join(),让主进程等待子进程结束才继续走后续的逻辑。

思考题

能不能每个子进程调用start() 之后,然后直接调用join() 类似:

p1.start()p1.join()p2.start()p2.join()

以上就是python 多线程中join()的作用的详细内容,更多关于python 多线程join()的资料请关注易盾网络其它相关文章!