能力配不上野心,是所有烦扰的根源。这个世界是公平的,你要想得到,就得学会付出和坚持。每个人都是通过自己的努力,去决定生活的样子!
总结:
- join()方法可以在当前线程位置阻塞主进程,带执行join()的进程结束后再继续执行主进程的代码逻辑;
- 原则:主线程结束的时候;只要还有一个non-daemon就等待;否则就退出;
- 不太推荐使用join方法,使用了join方法,主线程就被阻塞住了;
主线程为non-daemon线程,当我们创建daemon线程的时候,我们不希望daemon线程未执行就结束的时候;
该怎么办呢?
1. join方法
join()方法可以在当前位置阻塞主进程,带执行join()的进程结束后再继续执行主进程的代码逻辑
使用了join方法后,daemon线程执行完了,主线程才退出了。
先看一个简单的例子,看看效果;
# 设置join,取消join对比一下
import time
import threading
def foo(n):
for i in range(n):
print(i)
time.sleep(1)
t1 = threading.Thread(target=foo, args=(10,), daemon=True)
t1.start()
t1.join() # 设置join,取消join对比一下
print('Main Thread Exiting')
#----------------------------------------------------------------------------------------
0
1
2
3
4
5
6
7
8
9
Main Thread Exiting
join(timeout=None),是线程的标准方法之一。
一个线程中调用另一个线程的join方法,调用者将被阻塞,直到被调用线程终止。
一个线程可以被join多次。
timeout参数指定调用者等待多久,没有设置超时,就一直等到被调用线程结束。
调用谁的join方法,就是 join谁,就要等谁;t1.join();主线程阻塞,join t1,运行t1后,主线程才结束;
import time
import threading
def work():
time.sleep(10)
print('work')
def bar():
t = threading.Thread(target=work)
t.start()
time.sleep(5)
print('bar')
def foo():
time.sleep(2)
print('foo')
# 主线程是non-daemon线程
t1 = threading.Thread(name='worker',target=bar, daemon=True)
t1.start()
t1.join()
time.sleep(1)
print('Main Thread Exiting')
#-------------------------------------------------------------------------------------
bar
Main Thread Exiting
易混淆点:
- 主线程被阻塞,运行join t1线程,t1创建新线程;主线程执行完毕,t1只要结束(与是否创建新线程无关),进程结束;
2. daemon线程应用场景
简单来说就是,本来并没有daemon thread,为了简化程序员的工作,让他们不用去记录和管理那些后台线程,创造了一个 daemon thread的概念;这个概念唯一的作用就是,当你把一个线程设置为daemon,他会随着主线程的退出而退出。
主要应用场景有:
1、后台任务。如发送心跳包、监控,这种场景最多;
2、主线程工作才有用的线程,如主线程中维护这公共的资源,主线程已经清理了,准备退出,而工作先后才能使用这些资源工作也没有意义了,一起退出最合适。
3、随时可以被终止的线程;
如果主线程退出,想所有其它工作线程一起退出,就使用daemon=True来创建工作线程。
比如,开启一个线程定时判断WEB服务是否正常工作,主线程退出,工作线程也没有必须存在了,应该随着主线程退出一起退出。这种daemon线程一旦创建,就可以忘记它了,只用关心主线程什么时候退出就行了。
daemon线程,简化了程序员手动关闭线程的工作。
混淆点:
如果在non-daemon线程A中,对另一个daemon线程B使用了join方法,这个线程B设置成daemon就没有什么意义了,因为non-daemon线程A总是要等待B。
如果在一个daemon线程C中,对另一个daemon线程D使用了join方法,只能说明C要等待D,主线程退出,C和D不管是否结束,也不管它们谁等谁,都要被杀掉。