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

目录

• python线程池ThreadPoolExhttp://www.devze.comecutor,传单个参数和多个参数
• 这是线程池传单个参数的
• 下面是传多个参数的
• python线程池传入多个参数 ThreadPoolExecutor.submit 多参数支持
• 总结

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

这是线程池传单个参数的

fandroidrom 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():
    pythonres = pool.submit(test,j)
    kk = res.result()

下面是传多个参数的

from concurren编程客栈t.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 =开发者_Go教程[filepath,thu1,Words]

newTask=executor.submit(lambda p: doFileParse(*p),args)

总结

以上为个人经验，希望能给大家一个参考，也希望大家多多支持我们。