说明

1、标准库为我们提供concurrent.futures模块提供两种类型：线程池和进程池。

2、该模块通过submit返回一个future对象。

它是未来可预测的对象。通过它，您可以了解线程状态的主线程（或过程）或任务执行的状态和返回值。

实例

importflask
importjson
importtime
fromconcurrent.futuresimportThreadPoolExecutor#需安装

app=flask.Flask(__name__)
pool=ThreadPoolExecutor()


defread_file():
time.sleep(0.1)
return"fileresult"


defread_db():
time.sleep(0.2)
return"dbresult"


defread_api():
time.sleep(0.3)
return"apiresult"


@app.route("/")
defindex():
result_file=pool.submit(read_file)
result_db=pool.submit(read_db)
result_api=pool.submit(read_api)

returnjson.dumps({
"result_file":result_file.result(),
"result_db":result_db.result(),
"result_api":result_api.result(),
})


if__name__=="__main__":
app.run()

以上是Python中的concurenten.使用futures模块，希望对大家有所帮助。更多Python学习指导：python基础教程

本文教程操作环境：windows7系统Python 3.9.1，DELL G3电脑。