时间:2021-05-22
一 前言
温习python 多进程语法的时候,对 join的理解不是很透彻,本文通过代码实践来加深对 join()的认识。
multiprocessing 是python提供的跨平台版本的多进程模块。multiprocessing可以充分利用多核,提升程序运行效率。multiprocessing支持子进程,通信和共享数据,执行不同形式的同步,提供了Process、Queue、Pipe、Lock等组件。不过今天重点了解 join。后续文章会逐步学习介绍其他组件或者功能。
二 动手实践
join()方法可以在当前位置阻塞主进程,带执行join()的进程结束后再继续执行主进程的代码逻辑。
# encoding: utf-8"""author: yangyi@youzan.comtime: 2019/7/30 11:20 AMfunc:"""from multiprocessing import Processimport osimport timedef 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()的资料请关注其它相关文章!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
Python多线程编程时,经常会用到join()和setDaemon()方法,今天特地研究了一下两者的区别。1、join()方法:主线程A中,创建了子线程B,并
之前用python的多线程,总是处理不好进程和线程之间的关系。后来发现了join和setDaemon函数,才终于弄明白。下面总结一下。1.使用join函数后,主
1.多线程的作用简而言之,多线程是并行处理相互独立的子任务,从而大幅度提高整个任务的效率。2.Python中的多线程相关模块和方法Python中提供几个用于多线
前言:java中的join()方法在多线程中会涉及到,这个方法最初理解起来可能有点抽象,用一两次大概就懂了。简单说就是当前线程等待调用join方法的线程结束才能
本文实例讲述了Python中threading模块join函数用法。分享给大家供大家参考。具体分析如下:join的作用是众所周知的,阻塞进程直到线程执行完毕。通