欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Python中threading的join和setDaemon的区别[带例子]

程序员文章站 2022-07-05 15:32:19
python的进程和线程经常用到,之前一直不明白threading的join和setDaemon的区别和用法,今天特地研究了一下。multiprocessing中也有这两个方法,同样适用,这里以threading的join和setDaemon举例。 1、join ()方法:主线程A中,创建了子线程B ......

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

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

原型: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)