python的进程和线程经常用到,之前一直不明白threading的join和setDaemon的区别和用法,今天特地研究了一下。multiprocessing中也有这两个方法,同样适用,这里以threading的join和setDaemon举例。

1、join ()方法:主线程A中,创建了子线程B,并且在主线程A中调用了B.join(),那么,主线程A会在调用的地方等待,直到子线程B完成操作后,才可以接着往下执行,那么在调用这个线程时可以使用被调用线程的join方法。

SRE实战 互联网时代守护先锋,助力企业售后服务体系运筹帷幄!一键直达领取阿里云限量特价优惠。

原型:join([timeout])

里面的参数时可选的,代表线程运行的最大时间,即如果超过这个时间,不管这个此线程有没有执行完毕都会被回收,然后主线程或函数都会接着执行的。

例子:

# -*- coding: utf-8 -*-

from threading import Thread
from time import sleep

def search():
    sleep(5)
    print 2

if __name__ == '__main__':
    t = Thread(target=search)
    t.start()
    # t.join()
    print 1

执行后的结果:

1
2

运行后,当打印完1停顿了5秒后才打印2。解释:线程t开始后,需要睡5s,主线程并没有等待线程t执行完,就开始往下执行。

现在,我们把t.join()注释去掉(其他代码不变),看看有什么变化,例子:

# -*- coding: utf-8 -*-

from threading import Thread
from time import sleep

def search():
    sleep(5)
    print 2

if __name__ == '__main__':
    t = Thread(target=search)
    t.start()
    t.join()
    print 1

 

执行后的结果:

2
1

运行后,发现停顿了5秒后才打印2,然后立即打印了1。解释:当程序运行到t.join()时,停在了t.join()处,等待线程t执行完,然后开始往下执行。

2.

2、setDaemon()方法。主线程A中,创建了子线程B,并且在主线程A中调用了B.setDaemon(),这个的意思是,把主线程A设置为守护线程,这时候,要是主线程A执行结束了,就不管子线程B是否完成,一并和主线程A退出,这就是setDaemon方法的含义。此外,还有个要特别注意的:必须在start() 方法调用之前设置,如果不设置为守护线程,程序会被无限挂起。

例子:

from threading import Thread
from time import sleep

def search():
    for i in range(5):
        sleep(1)
        print 2

if __name__ == '__main__':
    t = Thread(target=search)
    # t.setDaemon(True)
    t.start()
    print 1

 

执行后的结果:

1
2
2
2
2
2

运行过程中,程序还没运行完时,关闭程序。会发现程序还在打印2。这是因为主线程默认等待线程t执行完才关闭,主线程执行完,子线程t没有执行完,程序就被挂起,一直等待子线程执行完毕。

现在,我们把t.setDaemon(True)的注释删掉,再执行查看结果。例子:

# -*- coding: utf-8 -*-

from threading import Thread
from time import sleep

def search():
    for i in range(5):
        sleep(1)
        print 2

if __name__ == '__main__':
    t = Thread(target=search)
    t.setDaemon(True)
    t.start()
    print 1

执行结果:

1

执行发现,程序在打印完1后就停止了。这是因为主线程执行完以后,不再等待子线程是否执行完,立马结束。

threading的join和setDaemon的区别总结:如果主线程中调用了join(),程序会阻塞在调用处,直到子线程执行完才往下执行。如果没调用,主线程则无需等待,直接往下执行。如果主线程中调用了setDaemon(True),则当程序关闭或者执行完后,子线程立马关闭,不管其是否执行完。如果主线程中没有调用setDaemon(True),则当程序关闭或者执行完后,子线程会继续执行,直到执行完。join管阻塞,setDaemon管结束。

正常开发中,当开启了多线程,为了不让程序阻塞,同时主线程关闭时,子线程能够都同时关闭,会用下面的方法。

# -*- coding: utf-8 -*-

from threading import Thread
from time import sleep

def search():
    for i in range(5):
        sleep(1)
        print 2

def insert():
    for i in range(5):
        sleep(0.9)
        print 3

if __name__ == '__main__':
    task1 = Thread(target=search)
    task2 = Thread(target=insert)
    task1.setDaemon(True)
    task2.setDaemon(True)
    task1.start()
    task2.start()
    while True:
        sleep(10)

 

扫码关注我们
微信号:SRE实战
拒绝背锅 运筹帷幄