python线程join方法与seDaemon方法

xiaoxue85

前言
　　基于上篇文章之后,我们了解了python程序执行流程,为什么要使用线程,以及什么情况下使用python线程,本文继此之后说说python多线程编程时,经常用到的join()和setDaemon()方法.

join()方法
　　join ()方法：主线程(主程序)A中，创建了子线程B，并且在主线程A中调用了B.join()方法(或多个线程中的一个join()方法)，那么，主线程A会在调用的地方等待，直到子线程B完成操作后，才可以接着往下执行.
　　无join()方法代码示例:
　　

import threading　　
import time
　　

　　
class MyThread(threading.Thread):

　　def __init__(self,>　　threading.Thread.__init__(self)

　　self.id =>　　print("I am child thread %s" % self.name)
　　

　　def run(self):
　　time.sleep(6)  # 模拟阻塞
　　print("%s running:%s" % (self.name, self.id))
　　

　　
if __name__ == "__main__":
　　threads = []
　　for i in range(5):
　　threads.append(MyThread(i))    #生成线程实例
　　for t in threads:     #
　　

　　t.start()       #由主线程启动所有线程
　　

　　for i in range(5):        #返回到主线程继续
　　print("I am in Master Thread.",i)
　　

　　运行结果:

　　以上执行结果没有使用join()方法;主线程先生成生成子线程,子线程执行,由于执行过程中阻塞,返回执行主线程(主程序)内容,此间暂停了等主线程执行完后,子线程执行结束返回了执行结果.
　　加入join()方法程序执行示例
　　

import threading　　
import time
　　

　　
class MyThread(threading.Thread):

　　def __init__(self,>　　threading.Thread.__init__(self)

　　self.id =>　　print("I am child thread %s" % self.name)
　　

　　def run(self):
　　time.sleep(6)  # 模拟阻塞
　　print("%s running:%s" % (self.name, self.id))
　　

　　
if __name__ == "__main__":
　　threads = []
　　for i in range(5):
　　threads.append(MyThread(i))    #生成线程实例
　　for t in threads:     #
　　

　　t.start()       #由主线程启动所有线程
　　t.join()            #等待所有线程运行结束,没有这条,由于线程里run中有阻塞,故主线程不等,而直接运行下面的for i
　　

　　for i in range(5):        #返回到主线程继续
　　print("I am in Master Thread.",i)
　　

　　执行结果如图:

　　上面的程序代码只是加了join()方法,在有join时 等待所有子线程执行完毕(阻塞),(准确的说是等最后一个线程执行完毕)  再切回主线程(主程序)执行.
　　小结:jion()方法就是为了让主线程等待子线执行完并返回结果后,再执行主线程剩下的内容.子线程不执行完,主线程就一直等待状态.没有加join()方法时主线程只是开启子线程,至于子线程执行多久何里返回值,主线程暂时不管,仍然执行剩下的主程序,多次运行以上程序你会发现,在开启子线程后,主线程执行剩下的主程序时,有时没有执行完主程序,期间夹杂着子线程执行完返回的结果.这是有可能的,并不是程序出错.

setDaemon()方法
　　setDaemon()方法:主线程A中，创建了子线程B，并且在主线程A中调用了B.setDaemon()方法(B子线程只是其中子线程的一个)意思是，把主线程A设置为守护线程，这时候，要是主线程A执行结束了，就不管子线程B是否完成,一并和主线程A退出.这就是setDaemon方法的含义，这基本上和join是相反的作用。此外，需要特别注意的是：必须在start() 方法调用之前设置.
　　在以上的代码中稍稍修改即可看出setDaemon方法的作用;
　　示例代码:
　　

import threading　　
import time
　　

　　
class MyThread(threading.Thread):

　　def __init__(self,>　　threading.Thread.__init__(self)

　　self.id =>　　print("I am child thread %s" % self.name)
　　

　　def run(self):
　　x = 0
　　if self.id == 0:
　　time.sleep(5)     #模拟阻塞
　　print("%s running:%s" %(self.name,self.id))
　　else:
　　time.sleep(2)  # 模拟阻塞(程序执行时间)
　　print("%s running:%s" % (self.name, self.id))
　　

　　
if __name__ == "__main__":
　　threads = []
　　for i in range(5):
　　threads.append(MyThread(i))    #生成线程实例
　　threads[0].setDaemon(True)        # 0号线程  不受保护,主线程结束时,如果没有运行完也结束掉
　　for t in threads:     #
　　

　　t.start()       #由主线程启动所有线程
　　t.join()            #等待所有线程运行结束,没有这条,由于线程里run中有阻塞,故主线程不等,而直接运行下面的for i
　　

　　for i in range(5):        #返回到主线程继续
　　print("I am in Master Thread.",i)
　　

　　运行结果:

　　说明:
　　Threads[0].setDaemon(True)    对0号线程 设置不受保护,主线程结束时,如果没有运行完也结束掉;在程序中我设置了对Threads-0阻塞为5秒,而其他的子线程为2秒,0号线程设置了不受保护,所以在主线程执行完后,就退出了,不再等待.而其他子线程不受影响,可以把Thread[0]换成其他子线程,效果是一样的.

总结:
　　通过以上对join()    setDaemon()方法的实验,我们总结如下:
　　程序运行是一个进程,一个进程最少有一个线程，这个线程就是主线程;执行一个主线程，如果主线程又创建一个或多个子线程，主线程和子线程就分兵多路，分别运行，那么当主线程完成想退出时，会检验子线程是否完成。如果子线程未完成，则主线程会等待子线程完成后再退出。就要加join()方法实现;但是有时候我们需要的是，只要主线程完成了，不管子线程是否完成，都要和主线程一起退出，这时就可以用setDaemon方法了。