您好,登錄后才能下訂單哦!
這篇文章主要介紹了python線程池ThreadPoolExecutor怎么傳單個(gè)參數(shù)和多個(gè)參數(shù)的相關(guān)知識(shí),內(nèi)容詳細(xì)易懂,操作簡(jiǎn)單快捷,具有一定借鑒價(jià)值,相信大家閱讀完這篇python線程池ThreadPoolExecutor怎么傳單個(gè)參數(shù)和多個(gè)參數(shù)文章都會(huì)有所收獲,下面我們一起來(lái)看看吧。
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))
這行代碼要拆開來(lái)看
首先就是匿名函數(shù) :lambda cxp:test(*cxp) 這是第一步
這個(gè)的意思是:傳cxp參數(shù),傳到test里
第二步就是 submit(lambda cxp:test(cxp),(j ,k))
sumbit的方法是要傳兩個(gè)參數(shù)的,第一個(gè)是一個(gè)函數(shù),第二個(gè)是這個(gè)函數(shù)的參數(shù)
剛剛匿名函數(shù)就是第一個(gè)參數(shù),然后(j,k)是第二參數(shù),這個(gè)參數(shù)是要傳給函數(shù)的,于是 (j,k)就給了cxp
from concurrent.futures import ThreadPoolExecutor,as_completed def doFileParse(filepath,segment,wordslist): print(filepath) print(segment) #調(diào)用方法 #實(shí)質(zhì)就是通過lambda表達(dá)式過渡。傳入的參數(shù)是一個(gè),但是通過lambda表達(dá)多后拆散為多個(gè)傳入。這是很巧妙的方法,實(shí)際 就是 *p 這個(gè)表達(dá)式。 args =[filepath,thu1,Words] newTask=executor.submit(lambda p: doFileParse(*p),args)
關(guān)于“python線程池ThreadPoolExecutor怎么傳單個(gè)參數(shù)和多個(gè)參數(shù)”這篇文章的內(nèi)容就介紹到這里,感謝各位的閱讀!相信大家對(duì)“python線程池ThreadPoolExecutor怎么傳單個(gè)參數(shù)和多個(gè)參數(shù)”知識(shí)都有一定的了解,大家如果還想學(xué)習(xí)更多知識(shí),歡迎關(guān)注億速云行業(yè)資訊頻道。
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。