python concurrent.futures模塊的使用測試

Posted on by

概述

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使用內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：