前言
基于上篇文章之后,我们了解了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, id):
threading.Thread.__init__(self)
self.id = 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, id):
threading.Thread.__init__(self)
self.id = 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, id):
threading.Thread.__init__(self)
self.id = 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方法了。
