xkrs_manan/RODY
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

websocket

Browse Source
This commit is contained in:
wudong 2022-11-25 17:30:43 +08:00
parent 00dc9b02eb
commit c21f7a8d38
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/controller/AlgorithmController.py
View File

@ -47,8 +47,9 @@ def start_train_algorithm():
def wrapped_function(): def wrapped_function():
param = request.args.get('param') param = request.args.get('param')
id = request.args.get('id') id = request.args.get('id')
t = Thread(target=func, args=(param, id)) dict = manager.active_connections_dist
#t = Process(target=func, args=(param, id), name=id) # t = Thread(target=func, args=(param, id))
t = Process(target=func, args=(param, id, dict[id]), name=id)
set_value(key=id, value=False) set_value(key=id, value=False)
t.start() t.start()
return output_wrapped(0, 'success', '成功') return output_wrapped(0, 'success', '成功')
@ -302,6 +303,7 @@ def error_return(id: str, data):
# 启动训练 # 启动训练
@start_train_algorithm() @start_train_algorithm()
def train_R0DY(params_str, id, getsomething): def train_R0DY(params_str, id, getsomething):
manager.active_connections_dist[id] = getsomething
print('**********************************') print('**********************************')
print(params_str) print(params_str)
print('**********************************') print('**********************************')