python concurrent.futures模塊的測試方法

本篇內(nèi)容主要講解“python concurrent.futures模塊的測試方法”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學(xué)習(xí)“python concurrent.futures模塊的測試方法”吧!

概述

concurrent.futures 是 3.2 中引入的新模塊，它為異步執(zhí)行可調(diào)用對象提供了高層接口。
可以使用 ThreadPoolExecutor 來進行多線程編程，ProcessPoolExecutor 進行多進程編程，兩者實現(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的進一步抽象，對編寫線程池/進程池提供了直接的支持.

#! /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()

不論你在什么時候開始，重要的是開始之后就不要停止。不論你在什么時候結(jié)束，重要的是結(jié)束之后就不要悔恨。

到此，相信大家對“python concurrent.futures模塊的測試方法”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！