您好,登錄后才能下訂單哦!
這篇文章主要講解了“python線程池ThreadPoolExecutor如何傳單個參數(shù)和多個參數(shù)”,文中的講解內(nèi)容簡單清晰,易于學(xué)習(xí)與理解,下面請大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“python線程池ThreadPoolExecutor如何傳單個參數(shù)和多個參數(shù)”吧!
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))
這行代碼要拆開來看
首先就是匿名函數(shù) :lambda cxp:test(*cxp) 這是第一步
這個的意思是:傳cxp參數(shù),傳到test里
第二步就是 submit(lambda cxp:test(cxp),(j ,k))
sumbit的方法是要傳兩個參數(shù)的,第一個是一個函數(shù),第二個是這個函數(shù)的參數(shù)
剛剛匿名函數(shù)就是第一個參數(shù),然后(j,k)是第二參數(shù),這個參數(shù)是要傳給函數(shù)的,于是 (j,k)就給了cxp
from concurrent.futures import ThreadPoolExecutor,as_completed def doFileParse(filepath,segment,wordslist): print(filepath) print(segment) #調(diào)用方法 #實質(zhì)就是通過lambda表達式過渡。傳入的參數(shù)是一個,但是通過lambda表達多后拆散為多個傳入。這是很巧妙的方法,實際 就是 *p 這個表達式。 args =[filepath,thu1,Words] newTask=executor.submit(lambda p: doFileParse(*p),args)
感謝各位的閱讀,以上就是“python線程池ThreadPoolExecutor如何傳單個參數(shù)和多個參數(shù)”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對python線程池ThreadPoolExecutor如何傳單個參數(shù)和多個參數(shù)這一問題有了更深刻的體會,具體使用情況還需要大家實踐驗證。這里是億速云,小編將為大家推送更多相關(guān)知識點的文章,歡迎關(guān)注!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進行舉報,并提供相關(guān)證據(jù),一經(jīng)查實,將立刻刪除涉嫌侵權(quán)內(nèi)容。