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))
立即学习“Python免费学习笔记(深入)”;
sumbit的方法是要传两个参数的,第一个是一个函数,第二个是这个函数的参数
刚刚匿名函数就是第一个参数,然后(j,k)是第二参数,这个参数是要传给函数的,于是 (j,k)就给了cxp
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线程池ThreadPoolExecutor怎么传单个参数和多个参数的详细内容,更多请关注php中文网其它相关文章!
python怎么学习?python怎么入门?python在哪学?python怎么学才快?不用担心,这里为大家提供了python速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号