python concurrent.futures模塊如何使用

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

概述

concurrent.futures 是 3.2 中引入的新模塊，它為異步執(zhí)行可調(diào)用對(duì)象提供了高層接口。
可以使用 ThreadPoolExecutor 來進(jìn)行多線程編程，ProcessPoolExecutor 進(jìn)行多進(jìn)程編程，兩者實(shí)現(xiàn)了同樣的接口，這些接口由抽象類 Executor 定義。
這個(gè)模塊提供了兩大類型，一個(gè)是執(zhí)行器類 Executor，另一個(gè)是 Future 類。
執(zhí)行器用來管理工作池，future 用來管理工作計(jì)算出來的結(jié)果，通常不用直接操作 future 對(duì)象，因?yàn)橛胸S富的 API。

說明

Python3.2開始，標(biāo)準(zhǔn)庫為我們提供了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()

關(guān)于“python concurrent.futures模塊如何使用”這篇文章的內(nèi)容就介紹到這里，感謝各位的閱讀！相信大家對(duì)“python concurrent.futures模塊如何使用”知識(shí)都有一定的了解，大家如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道。