python线程join方法与seDaemon方法
2017-11-29 12:30
459 查看
前言
基于上篇文章之后,我们了解了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)
运行结果:
![](http://i2.51cto.com/images/blog/201711/29/39412ce7df8a74525fcca108f5643434.png?x-oss-process=image/watermark,size_16,text_QDUxQ1RP5Y2a5a6i,color_FFFFFF,t_100,g_se,x_10,y_10,shadow_90,type_ZmFuZ3poZW5naGVpdGk=)
以上执行结果没有使用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)
执行结果如图:
![](http://i2.51cto.com/images/blog/201711/29/001b1e2cb46d4b2322dbaeccbfe8857d.png?x-oss-process=image/watermark,size_16,text_QDUxQ1RP5Y2a5a6i,color_FFFFFF,t_100,g_se,x_10,y_10,shadow_90,type_ZmFuZ3poZW5naGVpdGk=)
上面的程序代码只是加了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)
运行结果:
![](http://i2.51cto.com/images/blog/201711/29/d8b597056f9e195799ce5e16762bcc66.png?x-oss-process=image/watermark,size_16,text_QDUxQ1RP5Y2a5a6i,color_FFFFFF,t_100,g_se,x_10,y_10,shadow_90,type_ZmFuZ3poZW5naGVpdGk=)
说明:
Threads[0].setDaemon(True) 对0号线程 设置不受保护,主线程结束时,如果没有运行完也结束掉;在程序中我设置了对Threads-0阻塞为5秒,而其他的子线程为2秒,0号线程设置了不受保护,所以在主线程执行完后,就退出了,不再等待.而其他子线程不受影响,可以把Thread[0]换成其他子线程,效果是一样的.
总结:
通过以上对join() setDaemon()方法的实验,我们总结如下:程序运行是一个进程,一个进程最少有一个线程,这个线程就是主线程;执行一个主线程,如果主线程又创建一个或多个子线程,主线程和子线程就分兵多路,分别运行,那么当主线程完成想退出时,会检验子线程是否完成。如果子线程未完成,则主线程会等待子线程完成后再退出。就要加join()方法实现;但是有时候我们需要的是,只要主线程完成了,不管子线程是否完成,都要和主线程一起退出,这时就可以用setDaemon方法了。
相关文章推荐
- 笨方法学python习题13、14
- python pip 使用方法
- python逐行读取文件内容的三种方法
- Python字典的setdefault()方法
- python使用threading获取线程函数返回值的实现方法
- Windows cmd下运行python脚本报错“ImportError: No Module named ...”的解决方法
- python异常简单使用方法
- 1.Python浅复制和深复制——copy和deepcopy方法
- 【python学习笔记】Python实现协程yield方法和gevent库
- python处理字符串时出现的错误'ascii' codec can't decode byte 0xe9 in position 0: ordinal not in range(128)" 解决方法
- python遍历 truple list dictionary的几种方法总结
- python中引入包的时候报错AttributeError: module 'sys' has no attribute 'setdefaultencoding'解决方法?
- Python中还原JavaScript的escape函数编码后字符串的方法
- <<Python基础教程>>学习笔记 | 第09章 | 魔法方法、属性和迭代器
- python pip 使用方法
- pydiction(vim的python语法补全插件)安装方法
- 学习python的第三十六天-OS模块,特殊的方法
- 实例Python处理XML文件的方法
- 用Python获取腾迅财经HTTP信息股票数据的方法
- 三种方法实现PCA算法(Python)