Python线程退化问题
程序员文章站
2022-03-09 13:07:01
...
最近项目中有需求要在收到一些变更之后,推送到另一个系统,并且需要加入一些容错机制。按照之前的方式另开一个线程,但没有达到异步的效果,反而导致阻塞而不能立即返回。调试后,发现应在新线程中的推送部分代码,仍处在调用方线程中。大致代码如下
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'
........................................................
上一篇: coursera视频无法播放的解决方法
下一篇: 超分辨率 测试集处理(基于插值下采样)