From c20c3c10635ce78db4a86ce9c0bb1d02e90f525d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 08 八月 2023 17:40:42 +0800
Subject: [PATCH] 单例+缓存优化
---
trade/trade_result_manager.py | 26 +++++++++++++-------------
1 files changed, 13 insertions(+), 13 deletions(-)
diff --git a/trade/trade_result_manager.py b/trade/trade_result_manager.py
index e3f98e3..16709ce 100644
--- a/trade/trade_result_manager.py
+++ b/trade/trade_result_manager.py
@@ -30,9 +30,9 @@
# 瀹夊叏绗旀暟璁＄畻
f5 = dask.delayed(__buyL2SafeCountManager.save_place_order_info)(code, buy_single_index, buy_exec_index,
total_datas[-1]["index"])
- f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code)
- f7 = dask.delayed(DCancelBigNumComputer.cancel_success)(code)
- f8 = dask.delayed(LCancelBigNumComputer.cancel_success)(code)
+ f6 = dask.delayed(SecondCancelBigNumComputer().cancel_success)(code)
+ f7 = dask.delayed(DCancelBigNumComputer().cancel_success)(code)
+ f8 = dask.delayed(LCancelBigNumComputer().cancel_success)(code)
dask.compute(f1, f2, f5, f6, f7, f8)
@@ -54,9 +54,9 @@
@dask.delayed
def h_cancel(code, buy_single_index, buy_exec_index):
try:
- HourCancelBigNumComputer.place_order_success(code, buy_single_index, buy_exec_index,
- local_today_datas.get(code),
- local_today_num_operate_map.get(code))
+ HourCancelBigNumComputer().place_order_success(code, buy_single_index, buy_exec_index,
+ local_today_datas.get(code),
+ local_today_num_operate_map.get(code))
except Exception as e:
logging.exception(e)
logger_l2_error.exception(e)
@@ -64,7 +64,7 @@
@dask.delayed
def l_cancel(code):
try:
- LCancelBigNumComputer.del_watch_index(code)
+ LCancelBigNumComputer().del_watch_index(code)
except Exception as e:
logging.exception(e)
logger_l2_error.exception(e)
@@ -88,9 +88,9 @@
# 鍙栨秷涔板叆鏍囪瘑
f2 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_point)(code)
f3 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_cancel_point)(code)
- f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code)
- f7 = dask.delayed(DCancelBigNumComputer.cancel_success)(code)
- f8 = dask.delayed(LCancelBigNumComputer.cancel_success)(code)
+ f6 = dask.delayed(SecondCancelBigNumComputer().cancel_success)(code)
+ f7 = dask.delayed(DCancelBigNumComputer().cancel_success)(code)
+ f8 = dask.delayed(LCancelBigNumComputer().cancel_success)(code)
dask.compute(f1, f2, f3, f6, f7, f8)
@@ -99,7 +99,7 @@
code = "600246"
f2 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_point)(code)
f3 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_cancel_point)(code)
- f6 = dask.delayed(SecondCancelBigNumComputer.cancel_success)(code)
- f7 = dask.delayed(DCancelBigNumComputer.cancel_success)(code)
- f8 = dask.delayed(LCancelBigNumComputer.cancel_success)(code)
+ f6 = dask.delayed(SecondCancelBigNumComputer().cancel_success)(code)
+ f7 = dask.delayed(DCancelBigNumComputer().cancel_success)(code)
+ f8 = dask.delayed(LCancelBigNumComputer().cancel_success)(code)
dask.compute(f2, f3, f6, f7, f8)
--
Gitblit v1.8.0