Python线程池模块ThreadPoolExecutor用法分析
本文实例讲述了Python线程池模块ThreadPoolExecutor用法。分享给大家供大家参考，具体如下：
python3内置的有Threadingpool和ThreadPoolExecutor模块，两个都可以做线程池，当然ThreadPoolExecutor会更好用一些，而且也有ProcessPoolExecutor进程池模块，使用方法基本一致。
首先导入模块
from concurrent.futures import ThreadPoolExecutor
使用方法很简单，最常用的可能就是map方法和submit+as_completed
注意，一定要使用with，而不要使用for，如果你一定要用for，那么一定要手动进行executor.shutdown，而你使用了with方法的话，再with方法内部已经实现了wait(),在使用完毕之后可以自行关闭线程池，减少资源浪费。
使用map
with ThreadPoolExecutor(max_workers=2) as executor:
result = executor.map(map_fun, itr_arg)
'''map_fun：你传入的要执行的map函数
itr_arg：一个可迭代的参数，可以是列表字典等可迭代的对象
基本上和python的map函数一样
注意result并不是你map_fun返回的结果，而是一个生成器，如果要从中去结果，你可以使用列表生成式或者其他你想使用的方法
'''
for res in result:
print(res) #这个res就是你map_fun返回的结果，你可以在这里做进一步处理
使用submit+as_completed也可以很灵活
with ThreadPoolExecutor(max_workers=2) as executor:
future= executor.submit(fun, args)
'''
在这里你可以使用for循环来做，返回的是一个future对象
future_list=[]
for i in range(max_workers):
future= executor.submit(fun, args[i])
future_list.append(future)
'''
for res in ac_completed(futrue_list): #这个futrure_list是你future对象的列表
print(res.result()) #循环遍历时用.result()来取返回值
两种方式差不多，都可以很好的实现多线程任务，切记一定使用with!
更多关于Python相关内容感兴趣的读者可查看本站专题：《Python进程与线程操作技巧总结》、《Python数据结构与算法教程》、《Python函数使用技巧总结》、《Python字符串操作技巧汇总》、《Python入门与进阶经典教程》、《Python+MySQL数据库程序设计入门教程》及《Python常见数据库操作技巧汇总》
希望本文所述对大家Python程序设计有所帮助。
-
本文向大家介绍ThreadPoolExecutor线程池的使用方法，包括了ThreadPoolExecutor线程池的使用方法的使用技巧和注意事项，需要的朋友参考一下 ThreadPoolExecutor ThreadPoolExecutor线程池，java提供开发框架，管理线程的创建、销毁、优化、监控等。 有4种不同的任务队列: 1.ArrayBlockingQueue：基于数组结构的任务队列。
-
主要内容：1 核心线程预启动,1.1 prestartCoreThread启动一条,1.2 prestartAllCoreThreads启动全部,2 关闭线程池,2.1 shutdown温和停止,2.2 shutdownNow立即停止,3 hook钩子方法,4 线程池信息获取,4.1 awaitTermination等待终止,4.2 getTaskCount计划任务数量,4.3 getActiveCount工作线程数量,,,,,,,,,,,前面的文章中，我们介绍了ThreadPoolExecut
-
主要内容：1 execute核心提交方法,2 addWorker尝试添加新线程,2.1 addWorkerFailed添加Worker失败处理,3 Worker线程包装类,3.1 runWorker执行工作基于JDK1.8详细介绍了ThreadPoolExecutor线程池的execute方法源码！ 1 execute核心提交方法 public void execute(Runnable command) 传递一个Runnable任务对象，然后由线程池对它进行异步执行。没有办法检查Runnabl
-
主要内容：1 submit方法,1.1 Future submit(Runnable),1.2 Future submit(Runnable T),1.3 Future submit(Callable< T >),2 FutureTask的原理,2.1 FutureTask的概述,2.2 FutureTask的重要属性,2.3 FutureTask的构造器,2.4 run核心方法,2.5 cancel取消任务,,,,,,详细介绍了ThreadPoolExecutor线程池的submit方法的源码
-
本文向大家介绍Java ThreadPoolExecutor 线程池的使用介绍，包括了Java ThreadPoolExecutor 线程池的使用介绍的使用技巧和注意事项，需要的朋友参考一下 Executors Executors 是一个Java中的工具类. 提供工厂方法来创建不同类型的线程池. 从上图中也可以看出, Executors的创建线程池的方法, 创建出来的线程池都实现了 Executo
-
本文向大家介绍python线程池（threadpool）模块使用笔记详解，包括了python线程池（threadpool）模块使用笔记详解的使用技巧和注意事项，需要的朋友参考一下 最近在做一个视频设备管理的项目，设备包括（摄像机，DVR,NVR等），包括设备信息补全，设备状态推送，设备流地址推送等，如果同时导入的设备数量较多，如果使用单线程进行设备检测，那么由于设备数量较多，会带来较大的延时，因此