python concurrent.futures模塊如何使用

這篇文章主要介紹了python concurrent.futures模塊如何使用的相關知識，內容詳細易懂，操作簡單快捷，具有一定借鑒價值，相信大家閱讀完這篇python concurrent.futures模塊如何使用文章都會有所收獲，下面我們一起來看看吧。

概述

concurrent.futures 是 3.2 中引入的新模塊，它為異步執行可調用對象提供了高層接口。
可以使用 ThreadPoolExecutor 來進行多線程編程，ProcessPoolExecutor 進行多進程編程，兩者實現了同樣的接口，這些接口由抽象類 Executor 定義。
這個模塊提供了兩大類型，一個是執行器類 Executor，另一個是 Future 類。
執行器用來管理工作池，future 用來管理工作計算出來的結果，通常不用直接操作 future 對象，因為有豐富的 API。

說明

Python3.2開始，標準庫為我們提供了concurrent.futures模塊，它提供了ThreadPoolExecutor和ProcessPoolExecutor兩個類，實現了對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模塊如何使用”這篇文章的內容就介紹到這里，感謝各位的閱讀！相信大家對“python concurrent.futures模塊如何使用”知識都有一定的了解，大家如果還想學習更多知識，歡迎關注億速云行業資訊頻道。