最近项目中有需求要在收到一些变更之后，推送到另一个系统，并且需要加入一些容错机制。按照之前的方式另开一个线程，但没有达到异步的效果，反而导致阻塞而不能立即返回。调试后，发现应在新线程中的推送部分代码，仍处在调用方线程中。大致代码如下
from flask import Flask from threading import Thread import requests from requests.adapters import HTTPAdapter from requests.exceptions import ConnectionError app = Flask(__name__) s = requests.Session() s.mount('http://', HTTPAdapter(max_retries=3)) def time_consuming_task(msg1, msg2): print(msg1+msg2) data = {msg1: msg2} try: s.post('http://127.0.0.1:8088/test', json=data, timeout=5) except ConnectionError as e: print(e.message) @app.route('/') def index(): task = Thread(target=time_consuming_task("hello", " test")) task.start() return 'ok' if __name__ == '__main__': app.run(host='0.0.0.0', port=8888, threaded=True)仔细对比一些例子之后，发现Thread调用缺少了args参数，而把time_comsuming_task的参数直接写在target里。之后这个调用就退化成了函数调用，而非新启动一个线程。按照下面的修改index函数、加入args参数，就可以达到异步的效果了：index函数立即返回'ok'，过几秒后才返回超时。
........................................................ @app.route('/') def index(): task = Thread(target=time_consuming_task, args=("hello", " test")) task.start() return 'ok' ........................................................
