python concurrent.futures模塊的使用測試
concurrent.futures 是 3.2 中引入的新模塊,它為異步執(zhí)行可調(diào)用對象提供了高層接口。可以使用 ThreadPoolExecutor 來進(jìn)行多線程編程,ProcessPoolExecutor 進(jìn)行多進(jìn)程編程,兩者實現(xiàn)了同樣的接口,這些接口由抽象類 Executor 定義。這個模塊提供了兩大類型,一個是執(zhí)行器類 Executor,另一個是 Future 類。執(zhí)行器用來管理工作池,future 用來管理工作計算出來的結(jié)果,通常不用直接操作 future 對象,因為有豐富的 API。
說明Python3.2開始,標(biāo)準(zhǔn)庫為我們提供了concurrent.futures模塊,它提供了ThreadPoolExecutor和ProcessPoolExecutor兩個類,實現(xiàn)了對threading和multiprocessing的進(jìn)一步抽象,對編寫線程池/進(jìn)程池提供了直接的支持.
#! /usr/bin/env python# -*- coding: utf-8 -*-## -------------------------------------------------------------------------------# Name: demo3# Author: yunhgu# Date: 2021/7/8 15:17# Description: # -------------------------------------------------------------------------------import osimport timeimport threadingfrom concurrent.futures import ProcessPoolExecutor, ThreadPoolExecutor, as_completeddef work(x): time.sleep(1) temp = f'父進(jìn)程{os.getppid()}:子進(jìn)程{os.getpid()}:線程{threading.get_ident()}:{x}' return tempdef 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_listdef main(): print(f'主進(jìn)程:{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()

不論你在什么時候開始,重要的是開始之后就不要停止。不論你在什么時候結(jié)束,重要的是結(jié)束之后就不要悔恨。
到此這篇關(guān)于python concurrent.futures模塊的使用測試 的文章就介紹到這了,更多相關(guān)python concurrent使用內(nèi)容請搜索好吧啦網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持好吧啦網(wǎng)!
相關(guān)文章:
1. PHP使用Swagger生成好看的API文檔2. ASP.NET MVC使用jQuery ui的progressbar實現(xiàn)進(jìn)度條3. Python3 json模塊之編碼解碼方法講解4. Python 制作查詢商品歷史價格的小工具5. Python 如何調(diào)試程序崩潰錯誤6. Python 利用Entrez庫篩選下載PubMed文獻(xiàn)摘要的示例7. ASP基礎(chǔ)知識VBScript基本元素講解8. python使用jenkins發(fā)送企業(yè)微信通知的實現(xiàn)9. Python sublime安裝及配置過程詳解10. Python 合并拼接字符串的方法

網(wǎng)公網(wǎng)安備