redis连接池归还

Administrator

2023-08-03 4d321ae069fce2c0f6f7884bec8fa6c4ec534d1a

 ths/ths_util.py

@@ -178,19 +178,21 @@

def set_ths_dead_state(client_id, dead):
    redis = __redisManager.getRedis()
    key = "ths_state_dead_count-{}".format(client_id)
    if not dead:
        RedisUtils.setex(redis, key, tool.get_expire(), 0)
    else:
        RedisUtils.incrby(redis, key, 1)
        RedisUtils.expire(redis, key, tool.get_expire())
    try:
        key = "ths_state_dead_count-{}".format(client_id)
        if not dead:
            RedisUtils.setex(redis, key, tool.get_expire(), 0, auto_free=False)
        else:
            RedisUtils.incrby(redis, key, 1, auto_free=False)
            RedisUtils.expire(redis, key, tool.get_expire(), auto_free=False)
    finally:
        redis.connection_pool.disconnect()


# 同花顺是否卡死
def is_ths_dead(client_id):
    key = "ths_state_dead_count-{}".format(client_id)
    redis = __redisManager.getRedis()
    val = RedisUtils.get(redis, key)
    val = RedisUtils.get( __redisManager.getRedis(), key)
    if val is not None and int(val) >= 5:
        return True
    else: