redis连接池归还

Administrator

2023-08-04 1e607e90c08fa2b7a765360665cc392539e3ddec

 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__':