threading线程及线程池

threading中的setDaemon()：

import time
import threading									#线程模块def sub(i):print('子线程开始...')time.sleep(1)print(i)print('子线程结束！')def main():print('主线程开始...')start = time.time()#使用线程for i in range(5):								#开启5个线程# 第一个参数target是线程调用函数，第二个参数args是一个数组变量，用于给worker函数传参，有几个参数就写几个，用","分割，最后的逗号不能少，少了就不是数组了，就会出错。th = threading.Thread(target=sub, args=(i,))th.setDaemon(True)							#设置守护进程th.start()end = time.time()print("总运行时长：%s秒" % (end-start))print('主线程结束！')if __name__ == "__main__":main()

设置setDaemon()时，结果如下：

主线程开始...
子线程开始...
子线程开始...
子线程开始...
子线程开始...
子线程开始...
总运行时长：0.002000093460083008秒
主线程结束！

主线程结束后，子线程没有继续执行。
setDaemon()注释掉时，结果如下：

主线程开始...
子线程开始...
子线程开始...
子线程开始...
子线程开始...
子线程开始...
总运行时长：0.005000114440917969秒
主线程结束！
0
子线程结束！
1
子线程结束！
3
子线程结束！
2
子线程结束！
4
子线程结束！

主线程结束后，子线程继续执行。
结论：
若setDaemon()的参数为True，主线程结束且子线程尚未结束，则子线程也一并结束；
若setDaemon()的参数为False(默认值)，主线程结束且子线程尚未结束，则子线程继续执行。
注意：
setDaemon()必须设置在start()之前才有效。

threading中的join()：
join的作用就是检测子线程是否结束，没有结束就阻塞，直到子线程结束才接着执行下面的程序。

from time import sleep
from threading import Threaddef sub():print('子线程开始...')for i in range(10):print(i)sleep(1)print('子线程结束！')def main():print('主线程开始...')c = Thread(target=sub)c.start()c.join()										#阻塞，直到线程结束才执行下面的程序print('主线程结束！')if __name__ == '__main__':main()

有c.join()时，结果如下：

主线程开始...
子线程开始...
0
1
2
3
4
5
6
7
8
9
子线程结束！
主线程结束！

c.join()注释掉时，结果如下：

主线程开始...
子线程开始...
0
主线程结束！
1
2
3
4
5
6
7
8
9
子线程结束！

线程池：

import concurrent.futures
import timedef func(n):print('%d\n' % n)c = 0for i in range(3):c += 1print(c)time.sleep(1)

submit()方法：

def start_thread_pool():pool = concurrent.futures.ThreadPoolExecutor(2)		#创建一个总线程数为2的线程池li = [0, 1, 2, 3, 4]								#创建待执行线程(5个)for n in li:										#在循环中每次取出一个线程来执行func函数，线程池没有空闲线程时则会进入等待。pool.submit(func, n)							if __name__ == '__main__':start_thread_pool()print("已全部完成")

结果为：

01
2
3
1
已全部完成1
2
3
21
2
3
31
2
3
41
2
3

map()方法：

def start_thread_pool():pool = concurrent.futures.ThreadPoolExecutor(2)		#创建一个总线程数为2的线程池li = [0, 1, 2, 3, 4]								#创建待执行线程(5个)pool.map(func, li)									if __name__ == '__main__':start_thread_pool()print("已全部完成")

结果为：

01
2
3
1
已全部完成1
2
3
21
2
3
31
2
3
41
2
3

wait()方法：

def start_thread_pool():pool = concurrent.futures.ThreadPoolExecutor(2)		#创建一个总线程数为2的线程池li = [0, 1, 2, 3, 4]								#创建待执行线程(5个)main = [pool.submit(func, n) for n in li]			#必须为submit()concurrent.futures.wait(main)						#等待条件默认为return_when='ALL_COMPLETED'，等待所有任务都结束再继续执行下面的代码if __name__ == '__main__':start_thread_pool()print("已全部完成")

结果为：

01
2
3
11
2
3
21
2
3
31
2
3
41
2
3
已全部完成

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！