中断训练

app/configs/global_var.py

@@ -7,38 +7,27 @@
 @Desc：
 
 """
-import multiprocessing
+import json
-
+from app.utils.redis_config import redis_client
 
 
 def _init():  # 初始化
-    # 中断标志
+    dict = {}
-    global _global_dict
+    redis_client.get_redis().set("_global_dict", json.dumps(dict))
-    _global_dict = {}
 
-#     # ws列表存储
-#     global _active_connections
-#     _active_connections = multiprocessing.Manager().list()
-
-#     # ws字典存储
-#     global _active_connections_dist
-#     _active_connections_dist = multiprocessing.Manager().dict()
-
-
-# def get_active_connections():
-#     return _active_connections
-
-# def get_active_connections_dist():
-#     return _active_connections_dist
 
 def set_value(key, value):
     # 定义一个全局变量
-    _global_dict[key] = value
+    dict = redis_client.get_redis().get("_global_dict")
+    if dict is None:
+        dict = {}
+    dict[key] = value
+    redis_client.get_redis().set("_global_dict", json.dumps(dict))
 
 
 def get_value(key):
     # 获得一个全局变量，不存在则提示读取对应变量失败
     try:
-        return _global_dict[key]
+        return redis_client.get_redis().get("_global_dict")[key]
     except:
         print('读取' + key + '失败\r\n')