理解Python多线程中的join方法:拆解Threading模块的使用详解
最编程
2024-02-21 19:41:14
...
通过以下实例可以get到join()函数的作用:如果thread是某个子线程,则调用thread.join()的作用是确保thread子线程执行完毕后才能执行下一个线程。下面第一个例子中没有调用join()函数,故没有这个限制,所有线程执行顺序都不定。
第二个例子中在每个子线程启动start()后马上调用了join()函数,这就确保了对于每一个子线程,必须等它执行完毕后才能执行下一个程序,故子线程是按顺序执行的,且主线程中的print()方法是在所有的子线程执行完毕后才执行。
第三个例子中,对于子线程启动start()后没有马上调用join()函数,故子线程的执行顺序是不确定的,但是主线程中的print()前调用了每个子线程的join()函数,故print()要在所有的子线程执行完毕后才能执行。
(1)没有使用join()函数,线程执行顺序不定,主线程可能在所有子线程执行完之前就执行了
import threading
import time
def test(p):
time.sleep(0.001)
print(p)
ts = []
for i in range(15):
# target指定线程要执行的代码,args指定该代码的参数
th = threading.Thread(target=test, args=[i])
ts.append(th)
for i in ts:
i.start()
print("it is end !")
0
1
it is end !
4
2
3
5
(2)修改部分代码如下:每次启动子线程后,调用一次join()函数,可以看出线程按顺序执行,且主线程在所有子线程执行完之 后才执行。
for i in ts:
i.start()
# 此处的join函数子线程按顺序执行,即i线程跑完后才能继续跑下一个线程
i.join()
print("it is end !")
0
1
2
3
4
5
it is end !
(3)修改部分代码如下:可以看出子线程执行顺序不定,但是主线程是在所有子线程执行完毕之后才执行的。
for i in ts:
i.start()
# 此处的join函数使子线程全部跑完再继续往下跑子线程
for i in ts:
i.join()
print("it is end !")
1
0
4
5
2
3
it is end !
上一篇: K8s中的配置与储存:管理技巧与实践
下一篇: 进程和线程关系