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
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中文網其他相關文章!