前面文章介绍了如何创建一个线程,这一篇介绍join()函数。我们先通过下面的步骤来讲为什么要join()函数。
-
前面文章代码
1
2
3
4
5
6
7
8
9
10
11
12
13
14 1import threading
2
3
4def thread1_job():
5 print('这是一个添加的线程,它的名称是: %s' % threading.current_thread())
6
7
8def exampleFuc():
9 thread1 = threading.Thread(target=thread1_job)
10 thread1.start()
11
12exampleFuc()
13
14
- 我们修改下
我们在线程1里面写一个开始标记,然后写一个for循环,让它完成10次,这里没循环一次
就要执行时间等待(或休眠)0.5秒,十次都完成后,打印一个执行结束的标记。同样,我们在exampleFuc()里最后的一行代码也写一个全部事物结束的标记。然后,看看执行会发生什么。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 1import threading
2import time
3
4
5def thread1_job():
6 print('T1 开始\n')
7 for i in range(10):
8 time.sleep(0.5)
9 print('T1 结束\n')
10
11
12def exampleFuc():
13 thread1 = threading.Thread(target=thread1_job,name='T1')
14 thread1.start()
15 print('所有的任务都做完了。\n')
16
17exampleFuc()
18
运行一下,看看结果
1
2
3
4
5
6
7 1============= RESTART: C:/Users/Anthony/Desktop/thread_join.py =============
2T1 开始
3所有的任务都做完了。
4
5
6>>> T1 结束
7
运行结果分析:我们本来期待的是等线程1做完了十次,然后在主函数里,执行最后一行打印语句,告诉我们所有的事情都做完了。但是运行结果,发现,还没等T1完成十次任务,exampleFuc()就执行了最后一个打印语句。我们要如何实现,我们希望的顺序呢,这里就要用到线程中的join函数。
什么是join
首先,我们要知道,干活的是线程而不是进程。当一个线程调用Join方法的时候,主线程就被停止执行,直到该线程执行完毕。这里我们的thread1就是干活的,exampleFuc()就是一个主线程。接下来我们试试,thread1.join()看看会不会发生等thread1执行完,才会执行exampleFuc()里面的打印语句。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19 1import threading
2import time
3
4
5def thread1_job():
6 print('T1 开始\n')
7 for i in range(10):
8 time.sleep(0.5)
9 print('T1 结束\n')
10
11
12def exampleFuc():
13 thread1 = threading.Thread(target=thread1_job,name='T1')
14 thread1.start()
15 thread1.join()
16 print('所有的任务都做完了。\n')
17
18exampleFuc()
19
运行结果,果然和期待一样。
1
2
3
4
5
6
7
8
9
10 1============= RESTART: C:/Users/Anthony/Desktop/thread_join.py =============
2T1 开始
3
4T1 结束
5
6所有的任务都做完了。
7
8>>>
9
10