单例+缓存优化

Administrator

2023-08-08 b40a4d8694d7dcb7d7521c436950af40095be5ed

单例+缓存优化

 l2/cancel_buy_strategy.py

@@ -77,9 +77,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__s_big_num_cancel_compute_data_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_compute_data(code)
        CodeDataCacheUtil.set_cache(self.__s_big_num_cancel_compute_data_cache, code, val)
        return val
        return -1, 0, 0

    def __clear_data(self, code):
        CodeDataCacheUtil.clear_cache(self.__s_big_num_cancel_compute_data_cache, code)
@@ -350,9 +348,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__cancel_watch_indexs_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_watch_index_set(code)
        CodeDataCacheUtil.set_cache(self.__cancel_watch_indexs_cache, code, val)
        return val
        return None, -1, False

    # 保存执行位置后面的守护数据

@@ -376,9 +372,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__cancel_watch_indexs_exec_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_watch_index_set_after_exec(code)
        CodeDataCacheUtil.set_cache(self.__cancel_watch_indexs_exec_cache, code, val)
        return val
        return [], -1, 0, 0, False

    # 保存已经撤单的监听位置
    def __add_watch_canceled_indexes(self, code, indexes):
@@ -398,9 +392,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__cancel_watch_canceled_indexs_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_watch_canceled_index(code)
        CodeDataCacheUtil.set_cache(self.__cancel_watch_canceled_indexs_cache, code, val)
        return val
        return set()

    def __del_watch_canceled_index(self, code):
        CodeDataCacheUtil.clear_cache(self.__cancel_watch_canceled_indexs_cache, code)
@@ -427,9 +419,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__cancel_traded_progress_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_traded_progress(code)
        CodeDataCacheUtil.set_cache(self.__cancel_traded_progress_cache, code, val)
        return val
        return None, None

    # 保存结算位置
    def __save_compute_data(self, code, process_index, cancel_num):
@@ -450,9 +440,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__cancel_compute_data_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_compute_data(code)
        CodeDataCacheUtil.set_cache(self.__cancel_compute_data_cache, code, val)
        return val
        return -1, 0

    def __del_compute_data(self, code):
        CodeDataCacheUtil.clear_cache(self.__cancel_compute_data_cache, code)
@@ -839,9 +827,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__cancel_real_order_index_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_real_order_index(code)
        CodeDataCacheUtil.set_cache(self.__cancel_real_order_index_cache, code, val)
        return val
        return None

    def clear(self, code=None):
        if code:
@@ -956,10 +942,7 @@
        cache_result = CodeDataCacheUtil.get_cache(self.__cancel_watch_index_cache, code)
        if cache_result[0]:
            return cache_result[1]
        val = self.__get_watch_indexes(code)
        self.__cancel_watch_index_cache[code] = val
        CodeDataCacheUtil.set_cache(self.__cancel_watch_index_cache, code, val)
        return val
        return set()

    def del_watch_index(self, code):
        CodeDataCacheUtil.clear_cache(self.__cancel_watch_index_cache, code)