Python中concurrent.futures模塊的使用方法

這篇文章主要介紹了Python中concurrent.futures模塊的使用方法，具有一定借鑒價(jià)值，感興趣的朋友可以參考下，希望大家閱讀完這篇文章之后大有收獲，下面讓小編帶著大家一起了解一下。

1、說明

標(biāo)準(zhǔn)庫為我們提供了concurrent.futures模塊，它提供了線程池和進(jìn)程池兩個類。

該模塊通過submit返回的是一個future對象，它是一個未來可期的對象，通過它可以獲悉線程的狀態(tài)主線程(或進(jìn)程)中可以獲取某一個線程(進(jìn)程)執(zhí)行的狀態(tài)或者某一個任務(wù)執(zhí)行的狀態(tài)及返回值。

2、實(shí)例

import flask
import json
import time
from concurrent.futures import ThreadPoolExecutor   # 需安裝
 
app = flask.Flask(__name__)
pool = ThreadPoolExecutor()
 
 
def read_file():
    time.sleep(0.1)
    return "file result"
 
 
def read_db():
    time.sleep(0.2)
    return "db result"
 
 
def read_api():
    time.sleep(0.3)
    return "api result"
 
 
@app.route("/")
def index():
    result_file = pool.submit(read_file)
    result_db = pool.submit(read_db)
    result_api = pool.submit(read_api)
 
    return json.dumps({
        "result_file": result_file.result(),
        "result_db": result_db.result(),
        "result_api": result_api.result(),
    })
 
 
if __name__ == "__main__":
app.run()

感謝你能夠認(rèn)真閱讀完這篇文章，希望小編分享的“Python中concurrent.futures模塊的使用方法”這篇文章對大家有幫助，同時也希望大家多多支持億速云，關(guān)注億速云行業(yè)資訊頻道，更多相關(guān)知識等著你來學(xué)習(xí)!