From c3429ad2482280083c8399412e6b2f3f6144d3b7 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 04 八月 2023 10:48:45 +0800
Subject: [PATCH] redis连接池归还
---
code_attribute/gpcode_manager.py | 26 +++++++++++++-------------
1 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/code_attribute/gpcode_manager.py b/code_attribute/gpcode_manager.py
index 4eedbae..b7f1cfa 100644
--- a/code_attribute/gpcode_manager.py
+++ b/code_attribute/gpcode_manager.py
@@ -299,7 +299,7 @@
RedisUtils.sadd(redis_instance, "gp_list", d, auto_free=False)
CodesNameManager.set_second_code_names(name_codes)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 鏂板浠ｇ爜
@@ -319,7 +319,7 @@
old_name_codes[key] = name_codes[key]
CodesNameManager.set_second_code_names(old_name_codes)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
__gp_list_first_codes_cache = set()
@@ -359,7 +359,7 @@
old_name_codes[key] = name_codes[key]
CodesNameManager.set_first_code_names(old_name_codes)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 绉婚櫎棣栨澘浠ｇ爜
@@ -369,7 +369,7 @@
for code in codes:
RedisUtils.srem(redis_instance, "gp_list_first", code, auto_free=False)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 鑾峰彇棣栨澘浠ｇ爜
@@ -427,7 +427,7 @@
RedisUtils.expire(redis_instance, "gp_limit_up_list", tool.get_expire(), auto_free=False)
RedisUtils.setex(redis_instance, "gp_limit_up_list_update_time", tool.get_expire(), round(time.time() * 1000), auto_free=False)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 鑾峰彇娑ㄥ仠鍒楄〃
def get_limit_up_list():
@@ -437,7 +437,7 @@
auto_free=False), RedisUtils.smembers(redis_instance,
"gp_limit_up_list", auto_free=False)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
def rm_gp(code):
@@ -566,7 +566,7 @@
codes.add(code)
return codes
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 鏍规嵁浣嶇疆鑾峰彇姝ｅ湪鐩戝惉鐨勪唬鐮�
@@ -617,7 +617,7 @@
for code_ in codes_set:
RedisUtils.delete(redis_instance, code_, auto_free=False)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 鍒濆鍖栦綅缃�
@@ -635,7 +635,7 @@
for key in keys:
RedisUtils.setex(redis_instance, key, tool.get_expire(), "", auto_free=False)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
def clear_first_codes():
@@ -646,7 +646,7 @@
RedisUtils.delete(redis_instance, "first_code_record", auto_free=False)
RedisUtils.delete(redis_instance, "first_code_limited_up_record", auto_free=False)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 鑾峰彇鍙互鎿嶄綔鐨勪綅缃�
@@ -673,7 +673,7 @@
available_positions.append((client_id, int(key.replace("listen_code-{}-".format(client_id), ""))))
else:
codes.append((key, result))
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
# 鏌ヨ鏄惁鏈夐噸澶嶇殑浠ｇ爜
codes_set = set()
count = 0
@@ -711,7 +711,7 @@
if not code:
free_count += 1
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
return free_count
@@ -781,7 +781,7 @@
for code in codes:
RedisUtils.delete(redis_instance, "gp_operate-{}".format(code), auto_free=False)
finally:
- redis_instance.connection_pool.disconnect()
+ RedisUtils.realse(redis_instance)
if __name__ == '__main__':
--
Gitblit v1.8.0