Python 線程池模塊之多線程操作代碼
發(fā)布日期：2022-05-31 14:38 | 文章來(lái)源：CSDN
1、線程池模塊
引入
from concurrent.futures import ThreadPoolExecutor
2、使用線程池
一個(gè)簡(jiǎn)單的線程池使用案例
from concurrent.futures import ThreadPoolExecutor import time pool = ThreadPoolExecutor(10, 'Python') def fun(): time.sleep(1) print(1, end='') if __name__ == '__main__': # 列表推導(dǎo)式 [pool.submit(fun) for i in range(20) if True]
from concurrent.futures import ThreadPoolExecutor
import time
pool = ThreadPoolExecutor(10, 'Python')
def fun(arg1,arg2):
time.sleep(1)
print(arg1, end=' ')
print(arg2, end=' ')
if __name__ == '__main__':
# 列表推導(dǎo)式
[pool.submit(fun,i,i) for i in range(20) if True]
# 單個(gè)線程的執(zhí)行
task = pool.submit(fun,'Hello','world')
# 判斷任務(wù)執(zhí)行狀態(tài)
print(f'task status {task.done()}')
time.sleep(4)
print(f'task status {task.done()}')
# 獲取結(jié)果的函數(shù)是阻塞的，所以他會(huì)等線程結(jié)束之后才會(huì)輸出
print(task.result())
3、獲取結(jié)果
阻塞等待
print(task.result())
批量獲取結(jié)果
for future in as_completed(all_task): data = future.result()
阻塞主線程，等待執(zhí)行結(jié)束再執(zhí)行下一個(gè)業(yè)務(wù)
# 等待線程全部執(zhí)行完畢
wait(pool.submit(fun,1,2),return_when=ALL_COMPLETED)
print('')
以上就是Python 線程池模塊之多線程操作代碼的詳細(xì)內(nèi)容，更多關(guān)于Python 線程池模塊的資料請(qǐng)關(guān)注本站其它相關(guān)文章！
版權(quán)聲明：本站文章來(lái)源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請(qǐng)保持原文完整并注明來(lái)源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非maisonbaluchon.cn所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來(lái)源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來(lái)，僅供學(xué)習(xí)參考，不代表本站立場(chǎng)，如有內(nèi)容涉嫌侵權(quán)，請(qǐng)聯(lián)系alex-e#qq.com處理。
相關(guān)文章
關(guān)注官方微信