概述
concurrent.futures 是 3.2 中引入的新模塊，它為異步執(zhí)行可調(diào)用對(duì)象提供了高層接口。
可以使用 ThreadPoolExecutor 來(lái)進(jìn)行多線程編程，ProcessPoolExecutor 進(jìn)行多進(jìn)程編程，兩者實(shí)現(xiàn)了同樣的接口，這些接口由抽象類 Executor 定義。
這個(gè)模塊提供了兩大類型，一個(gè)是執(zhí)行器類 Executor，另一個(gè)是 Future 類。
執(zhí)行器用來(lái)管理工作池，future 用來(lái)管理工作計(jì)算出來(lái)的結(jié)果，通常不用直接操作 future 對(duì)象，因?yàn)橛胸S富的 API。
說(shuō)明
Python3.2開始，標(biāo)準(zhǔn)庫(kù)為我們提供了concurrent.futures模塊，它提供了ThreadPoolExecutor和ProcessPoolExecutor兩個(gè)類，實(shí)現(xiàn)了對(duì)threading和multiprocessing的進(jìn)一步抽象，對(duì)編寫線程池/進(jìn)程池提供了直接的支持.
#! /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"父進(jìn)程{os.getppid()}:子進(jìn)程{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"主進(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()
不論你在什么時(shí)候開始，重要的是開始之后就不要停止。不論你在什么時(shí)候結(jié)束，重要的是結(jié)束之后就不要悔恨。
到此這篇關(guān)于python concurrent.futures模塊的使用測(cè)試 的文章就介紹到這了,更多相關(guān)python concurrent使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:- python基于concurrent模塊實(shí)現(xiàn)多線程
- python 實(shí)現(xiàn)多進(jìn)程日志輪轉(zhuǎn)ConcurrentLogHandler
- Python并發(fā)concurrent.futures和asyncio實(shí)例
- Python concurrent.futures模塊使用實(shí)例
- python程序中的線程操作 concurrent模塊使用詳解
