通过以下实例可以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 !") it is end ! 5
(2)修改部分代码如下:每次启动子线程后,调用一次join()函数,可以看出线程按顺序执行,且主线程在所有子线程执行完之 后才执行。
for i in ts: i.start() # 此处的join函数子线程按顺序执行,即i线程跑完后才能继续跑下一个线程 i.join() print("it is end !") 3 it is end !
(3)修改部分代码如下:可以看出子线程执行顺序不定,但是主线程是在所有子线程执行完毕之后才执行的。
for i in ts: i.start() # 此处的join函数使子线程全部跑完再继续往下跑子线程 for i in ts: i.join() print("it is end !") 5 it is end !