Python：Flask使用ThreadPoolExecutor执行异步任务

测试代码

# -*- coding: utf-8 -*-

import time
from concurrent.futures import ThreadPoolExecutor

from flask import Flask, request

executor = ThreadPoolExecutor()

app = Flask(__name__)


# 模拟耗时任务
def run_job(name): time.sleep(5) print('run_job complete', name)


@app.route('/task')
def run_task(): """ 同步执行 http://127.0.0.1:5000/task """ name = request.args.get('name') run_job(name=name) return {'ret': 'ok'}


@app.route('/async_task')
def run_async_task(): """ 异步执行 http://127.0.0.1:5000/async_task """ name = request.args.get('name') executor.submit(run_job, name=name) return {'ret': 'ok'}


if __name__ == '__main__': app.run(debug=True)


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
  
16
  
17
  
18
  
19
  
20
  
21
  
22
  
23
  
24
  
25
  
26
  
27
  
28
  
29
  
30
  
31
  
32
  
33
  
34
  
35
  
36
  
37
  
38
  
39
  
40
  
41
  
42
  
43
  
44
  
45
  
46
  
47
 

apache2-utils压力测试工具测试：

# 使用说明：
$ ab -n 请求数 -c 并发数  URL


# 同步执行任务
$ ab -n 100 -c 10 http://127.0.0.1:5000/task

Time taken for tests:   55.100 seconds


# 异步执行任务
$ ab -n 100 -c 10 http://127.0.0.1:5000/async_task

Time taken for tests:   0.097 seconds


  

 

  
1
  
2
  
3
  
4
  
5
  
6
  
7
  
8
  
9
  
10
  
11
  
12
  
13
  
14
  
15
 

文章来源: pengshiyu.blog.csdn.net，作者：彭世瑜，版权归原作者所有，如需转载，请联系作者。

原文链接：pengshiyu.blog.csdn.net/article/details/114700730