Flask怎么实现异步任务

本篇内容介绍了“Flask怎么实现异步任务”的有关知识，在实际案例的操作过程中，不少人都会遇到这样的困境，接下来就让小编带领大家学习一下如何处理这些情况吧！希望大家仔细阅读，能够学有所成！

众所周知Flask默认不能很好的完成异步任务，那么我们如何在请求中快速返回状态并异步执行比较复杂耗时的任务呢？

话不多说看实现。

用到了ThreadPoolExecutor类

初始化线程池（这里初始化了10个线程）

from flask import Flask
from concurrent.futures import ThreadPoolExecutor

executor = ThreadPoolExecutor(10)
app = Flask(__name__)

然后将封装一个任务函数，在路由函数中调用任务函数放入到线程池中即可

@app.route('/api/gen', methods=['POST'])
def gen():
    data_list = request.get_json().get('data')
    print(data_list )
    executor.submit(gen_task, (data_list))  # data_list为gen_task函数的参数
    return {}


def gen_task(data_list):
    time.sleep(3)
    print('start gen task...')
    for item in data_list:
        gen_records(item['code'], item['num'])
    print('finish.')

这种方法对原代码的改动非常小，却非常有效。

“Flask怎么实现异步任务”的内容就介绍到这里了，感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站，小编将为大家输出更多高质量的实用文章！