本文實(shí)例講述了Python線程池模塊ThreadPoolExecutor用法。分享給大家供大家參考，具體如下：
python3內(nèi)置的有Threadingpool和ThreadPoolExecutor模塊，兩個(gè)都可以做線程池，當(dāng)然ThreadPoolExecutor會(huì)更好用一些，而且也有ProcessPoolExecutor進(jìn)程池模塊，使用方法基本一致。
首先導(dǎo)入模塊
from concurrent.futures import ThreadPoolExecutor
使用方法很簡單，最常用的可能就是map方法和submit+as_completed
注意，一定要使用with，而不要使用for，如果你一定要用for，那么一定要手動(dòng)進(jìn)行executor.shutdown，而你使用了with方法的話，再with方法內(nèi)部已經(jīng)實(shí)現(xiàn)了wait(),在使用完畢之后可以自行關(guān)閉線程池，減少資源浪費(fèi)。
使用map
with ThreadPoolExecutor(max_workers=2) as executor: result = executor.map(map_fun, itr_arg) '''map_fun：你傳入的要執(zhí)行的map函數(shù) itr_arg：一個(gè)可迭代的參數(shù)，可以是列表字典等可迭代的對(duì)象 基本上和python的map函數(shù)一樣 注意result并不是你map_fun返回的結(jié)果，而是一個(gè)生成器，如果要從中去結(jié)果，你可以使用列表生成式或者其他你想使用的方法 ''' for res in result: print(res) #這個(gè)res就是你map_fun返回的結(jié)果，你可以在這里做進(jìn)一步處理
使用submit+as_completed也可以很靈活
with ThreadPoolExecutor(max_workers=2) as executor: future= executor.submit(fun, args) ''' 在這里你可以使用for循環(huán)來做，返回的是一個(gè)future對(duì)象 future_list=[] for i in range(max_workers): future= executor.submit(fun, args[i]) future_list.append(future) ''' for res in ac_completed(futrue_list): #這個(gè)futrure_list是你future對(duì)象的列表 print(res.result()) #循環(huán)遍歷時(shí)用.result()來取返回值
兩種方式差不多，都可以很好的實(shí)現(xiàn)多線程任務(wù)，切記一定使用with!
希望本文所述對(duì)大家Python程序設(shè)計(jì)有所幫助。
新聞熱點(diǎn)
疑難解答
圖片精選
