说明
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电脑。