Python中threading的joi

py3study

发布于 2020-02-10 23:00:10

4800

发布于 2020-02-10 23:00:10

文章被收录于专栏：python3

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、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

执行后的结果：

运行过程中，程序还没运行完时，关闭程序。会发现程序还在打印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后就停止了。这是因为主线程执行完以后，不再等待子线程是否执行完，立马结束。

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)

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2019/05/06 ，如有侵权请联系 cloudcommunity@tencent.com 删除

python