python线程池ThreadPoolExecutor如何传单个参数和多个参数

其他教程   发布日期:2025年03月22日   浏览次数:107

这篇文章主要讲解了“python线程池ThreadPoolExecutor如何传单个参数和多个参数”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“python线程池ThreadPoolExecutor如何传单个参数和多个参数”吧!

    python线程池ThreadPoolExecutor,传单个参数和多个参数

    这是线程池传单个参数的

    1. from concurrent.futures import ThreadPoolExecutor,as_completed
    2. def test(a):
    3. print(a)
    4. qq = {"a":"1","b":"2","c":"3"}
    5. with ThreadPoolExecutor() as pool:
    6. for j ,k in qq.items():
    7. res = pool.submit(test,j)
    8. kk = res.result()

    下面是传多个参数的

    1. from concurrent.futures import ThreadPoolExecutor,as_completed
    2. def test(a,b):
    3. print(a,b)
    4. qq = {"a":"1","b":"2","c":"3"}
    5. with ThreadPoolExecutor() as pool:
    6. for j ,k in qq.items():
    7. res = pool.submit(lambda cxp:test(*cxp),(j ,k))
    8. 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 多参数支持

    1. from concurrent.futures import ThreadPoolExecutor,as_completed
    2. def doFileParse(filepath,segment,wordslist):
    3. print(filepath)
    4. print(segment)
    5. #调用方法
    6. #实质就是通过lambda表达式过渡。传入的参数是一个,但是通过lambda表达多后拆散为多个传入。这是很巧妙的方法,实际 就是 *p 这个表达式。
    7. args =[filepath,thu1,Words]
    8. newTask=executor.submit(lambda p: doFileParse(*p),args)

    以上就是python线程池ThreadPoolExecutor如何传单个参数和多个参数的详细内容,更多关于python线程池ThreadPoolExecutor如何传单个参数和多个参数的资料请关注九品源码其它相关文章!