欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

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'

........................................................