flask异步执⾏linux命令_Flask中简单实现异步任务,⾮常实⽤
的⼩技巧
众所周知Flask默认不能很好的完成异步任务,那么我们如何在请求中快速返回状态并异步执⾏⽐较复杂耗时的任务呢?
linux下的sleep函数话不多说看实现。
⽤到了ThreadPoolExecutor类
初始化线程池(这⾥初始化了10个线程)
from flask import Flask
from concurrent.futures import ThreadPoolExecutor
executor = ThreadPoolExecutor(10)
app = Flask(__name__)
然后将封装⼀个任务函数,在路由函数中调⽤任务函数放⼊到线程池中即可
@ute('/api/gen', methods=['POST'])
def gen():
data_list = _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 ')
for item in data_list:
gen_records(item['code'], item['num'])
print('finish.')
这种⽅法对原代码的改动⾮常⼩,却⾮常有效。

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。