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怎么实现异步任务”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注创新互联网站,小编将为大家输出更多高质量的实用文章!


文章名称:Flask怎么实现异步任务
URL分享:http://bzwzjz.com/article/pidhed.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: 成都网站制作 商城网站建设 成都网站设计 定制网站设计 上市集团网站建设 定制级高端网站建设 网站建设公司 响应式网站设计 成都网站设计公司 成都响应式网站建设公司 成都网站制作 成都网站制作 高端网站设计 成都网站建设 成都网站设计 高端定制网站设计 重庆网站建设 成都网站设计制作公司 自适应网站设计 高端品牌网站建设 成都做网站建设公司 网站建设方案