python线程池ThreadPoolExecutor,传单个参数和多个参数方式
更新时间:2023年03月14日 10:19:32 作者:东贝鸟
这篇文章主要介绍了python线程池ThreadPoolExecutor,传单个参数和多个参数方式,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
python线程池ThreadPoolExecutor,传单个参数和多个参数
这是线程池传单个参数的
from concurrent.futures import ThreadPoolExecutor,as_completed def test(a): print(a) qq = {"a":"1","b":"2","c":"3"} with ThreadPoolExecutor() as pool: for j ,k in qq.items(): res = pool.submit(test,j) kk = res.result()
下面是传多个参数的
from concurrent.futures import ThreadPoolExecutor,as_completed def test(a,b): print(a,b) qq = {"a":"1","b":"2","c":"3"} with ThreadPoolExecutor() as pool: for j ,k in qq.items(): res = pool.submit(lambda cxp:test(*cxp),(j ,k)) last= res.result())
主要就是 pool.submit(lambda cxp:test(*cxp),(j ,k))
这行代码要拆开来看
首先就是匿名函数 :lambda cxp:test(*cxp) 这是第一步
这个的意思是:传cxp参数,传到test里
第二步就是 submit(lambda cxp:test(cxp),(j ,k))
sumbit的方法是要传两个参数的,第一个是一个函数,第二个是这个函数的参数
刚刚匿名函数就是第一个参数,然后(j,k)是第二参数,这个参数是要传给函数的,于是 (j,k)就给了cxp
python线程池传入多个参数 ThreadPoolExecutor.submit 多参数支持
from concurrent.futures import ThreadPoolExecutor,as_completed def doFileParse(filepath,segment,wordslist): print(filepath) print(segment) #调用方法 #实质就是通过lambda表达式过渡。传入的参数是一个,但是通过lambda表达多后拆散为多个传入。这是很巧妙的方法,实际 就是 *p 这个表达式。 args =[filepath,thu1,Words] newTask=executor.submit(lambda p: doFileParse(*p),args)
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。
相关文章
python中找出numpy array数组的最值及其索引方法
下面小编就为大家分享一篇python中找出numpy array数组的最值及其索引方法,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧2018-04-04
最新评论