這篇文章主要介紹了python concurrent.futures模塊如何使用的相關知識,內(nèi)容詳細易懂,操作簡單快捷,具有一定借鑒價值,相信大家閱讀完這篇python concurrent.futures模塊如何使用文章都會有所收獲,下面我們一起來看看吧。
創(chuàng)新互聯(lián)公司長期為千余家客戶提供的網(wǎng)站建設服務,團隊從業(yè)經(jīng)驗10年,關注不同地域、不同群體,并針對不同對象提供差異化的產(chǎn)品和服務;打造開放共贏平臺,與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為江蘇企業(yè)提供專業(yè)的成都做網(wǎng)站、成都網(wǎng)站制作,江蘇網(wǎng)站改版等技術服務。擁有10余年豐富建站經(jīng)驗和眾多成功案例,為您定制開發(fā)。
concurrent.futures 是 3.2 中引入的新模塊,它為異步執(zhí)行可調用對象提供了高層接口。
可以使用 ThreadPoolExecutor 來進行多線程編程,ProcessPoolExecutor 進行多進程編程,兩者實現(xiàn)了同樣的接口,這些接口由抽象類 Executor 定義。
這個模塊提供了兩大類型,一個是執(zhí)行器類 Executor,另一個是 Future 類。
執(zhí)行器用來管理工作池,future 用來管理工作計算出來的結果,通常不用直接操作 future 對象,因為有豐富的 API。
Python3.2開始,標準庫為我們提供了concurrent.futures模塊,它提供了ThreadPoolExecutor和ProcessPoolExecutor兩個類,實現(xiàn)了對threading和multiprocessing的進一步抽象,對編寫線程池/進程池提供了直接的支持.
#! /usr/bin/env python # -*- coding: utf-8 -*-# # ------------------------------------------------------------------------------- # Name: demo3 # Author: yunhgu # Date: 2021/7/8 15:17 # Description: # ------------------------------------------------------------------------------- import os import time import threading from concurrent.futures import ProcessPoolExecutor, ThreadPoolExecutor, as_completed def work(x): time.sleep(1) temp = f"父進程{os.getppid()}:子進程{os.getpid()}:線程{threading.get_ident()}:{x}" return temp def sub_thread(): temp_list = [] with ThreadPoolExecutor(max_workers=3) as t: task_list = [t.submit(work, i) for i in range(5)] for task in as_completed(task_list): if task.done(): temp_list.append(task.result()) return temp_list def main(): print(f"主進程:{os.getpid()}") path_list = [] with ProcessPoolExecutor(max_workers=3) as p: task_list = [p.submit(sub_thread) for i in range(5)] for task in as_completed(task_list): if task.done(): path_list.append(task.result()) for path in path_list: print(path) if __name__ == "__main__": main()
關于“python concurrent.futures模塊如何使用”這篇文章的內(nèi)容就介紹到這里,感謝各位的閱讀!相信大家對“python concurrent.futures模塊如何使用”知識都有一定的了解,大家如果還想學習更多知識,歡迎關注創(chuàng)新互聯(lián)行業(yè)資訊頻道。