最近在開發同步mysql資料到redis的介面,因為資料同步涉及各種增刪查改,如果用同步實現,可能回造成連線超時、堵塞,所以,使用python實現非同步任務。
**實現
from flask import flask
import time
from concurrent.futures import threadpoolexecutor
executor = threadpoolexecutor(1)
def update_redis():
executor.submit(do_update)
return 'ok'
def do_update():
time.sleep(3)
print('start update')
if __name__ == '__main__':
這樣便能快速告訴介面呼叫者你已經知道需要同步資料,同時在後台進行所需要的操作,不至於因為等待而造成的無謂的阻塞以及超時
Flask非同步操作例項
後端 如下 from concurrent.futures import threadpoolexecutor upload file methods post defmain executor threadpoolexecutor 1 引數表示最大的執行緒數 executor.submit tes...
flask實現非同步任務
最近在開發同步mysql資料到redis的介面,因為資料同步涉及各種增刪查改,如果用同步實現,可能回造成連線超時 堵塞,所以,使用python實現非同步任務。from flask import flask import time from concurrent.futures import thre...
flask開啟非同步任務
from concurrent.futures import threadpoolexecutor executor threadpoolexecutor max workers 5 deffunc1 引數1 引數2 需要非同步的函式 pass defview executor.submit fun...