Python线程池模块ThreadPoolExecutor用法分析
程序员文章站
2024-01-17 10:57:34
本文实例讲述了python线程池模块threadpoolexecutor用法。分享给大家供大家参考,具体如下:
python3内置的有threadingpool和thre...
本文实例讲述了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程序设计有所帮助。
推荐阅读
-
Python数据分析模块pandas用法详解
-
python开发中module模块用法实例分析
-
Python3.5内置模块之time与datetime模块用法实例分析
-
Python3.5内置模块之shelve模块、xml模块、configparser模块、hashlib、hmac模块用法分析
-
Python处理命令行参数模块optpars用法实例分析
-
Python常用模块之requests模块用法分析
-
Python3.5内置模块之os模块、sys模块、shutil模块用法实例分析
-
Python3.5内置模块之random模块用法实例分析
-
Python数据持久化shelve模块用法分析
-
Python模块、包(Package)概念与用法分析