zoukankan      html  css  js  c++  java
  • Python中threading的join和setDaemon的区别[带例子]

    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)
  • 相关阅读:
    面相服务的架构SOA
    分布式系统架构体系
    分布式系统基础
    结对开发第一阶段,10天冲刺第八天
    结对开发第一阶段,10天冲刺第七天
    结对开发第一阶段,10天冲刺第六天
    结对开发第一阶段,10天冲刺第五天
    结对开发第一阶段,10天冲刺第四天
    结对开发第一阶段,10天冲刺第三天
    结对开发第一阶段,10天冲刺第二天
  • 原文地址:https://www.cnblogs.com/Haojq/p/10278365.html
Copyright © 2011-2022 走看看