From 965bd2fea182851382f61d9c7c1492d04546bf4d Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 16 八月 2023 12:42:24 +0800
Subject: [PATCH] ++++++++++++++++ 取消不必要的并行计算框架
---
l2/l2_data_manager_new.py | 23 +++++++++++------------
1 files changed, 11 insertions(+), 12 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index 1c35a8f..8114254 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -930,9 +930,9 @@
if not gpcode_manager.WantBuyCodesManager().is_in_cache(code):
if TradeTargetCodeModeManager().get_mode_cache() == TradeTargetCodeModeManager.MODE_ONLY_BUY_WANT_CODES:
return False, True, f"鍙拱鎯充拱鍗曚腑鐨勪唬鐮�"
- score_index = None #cls.__l2PlaceOrderParamsManagerDict[code].score_index
- score = None #cls.__l2PlaceOrderParamsManagerDict[code].score
- score_info =None #cls.__l2PlaceOrderParamsManagerDict[code].score_info
+ score_index = None # cls.__l2PlaceOrderParamsManagerDict[code].score_index
+ score = None # cls.__l2PlaceOrderParamsManagerDict[code].score
+ score_info = None # cls.__l2PlaceOrderParamsManagerDict[code].score_info
# lp = LineProfiler()
# lp.enable()
@@ -1130,20 +1130,19 @@
buy_nums,
buy_count, total_datas[compute_index], cls.volume_rate_info[code])
- f1 = dask.delayed(cls.__save_order_begin_data)(code, buy_single_index, compute_index, compute_index,
- buy_nums, buy_count, max_num_set_new,
- cls.volume_rate_info[code][0])
- f2 = dask.delayed(limit_up_time_manager.LimitUpTimeManager().save_limit_up_time)(code,
- total_datas[compute_index][
- "val"]["time"])
- f3 = dask.delayed(cls.__virtual_buy)(code, buy_single_index, compute_index, capture_time)
- f4 = dask.delayed(l2_data_manager.TradePointManager().delete_buy_cancel_point)(code)
+ cls.__save_order_begin_data(code, buy_single_index, compute_index, compute_index,
+ buy_nums, buy_count, max_num_set_new,
+ cls.volume_rate_info[code][0])
+ limit_up_time_manager.LimitUpTimeManager().save_limit_up_time(code,
+ total_datas[compute_index][
+ "val"]["time"])
+ cls.__virtual_buy(code, buy_single_index, compute_index, capture_time)
+ l2_data_manager.TradePointManager().delete_buy_cancel_point(code)
# 鏆傛椂涓嶉渶瑕�
# f5 = dask.delayed(L2LimitUpMoneyStatisticUtil.process_data)(code, buy_single_index,
# compute_index,
# buy_single_index,
# buy_exec_index, False)
- dask.compute(f1, f2, f3, f4)
# 宸茶骞惰澶勭悊
# # 璁板綍涔板叆淇″彿浣嶇疆
--
Gitblit v1.8.0