From 99b593ee7062f66036ad72aef0cb3c5a3c9a7e2b Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 06 九月 2023 10:26:21 +0800
Subject: [PATCH] 删除交易锁
---
l2/l2_data_manager_new.py | 12 ++----------
1 files changed, 2 insertions(+), 10 deletions(-)
diff --git a/l2/l2_data_manager_new.py b/l2/l2_data_manager_new.py
index b13d7a4..5e3d02c 100644
--- a/l2/l2_data_manager_new.py
+++ b/l2/l2_data_manager_new.py
@@ -207,7 +207,6 @@
class L2TradeDataProcessor:
unreal_buy_dict = {}
volume_rate_info = {}
- __trade_thread_lock_dict = {}
__codeActualPriceProcessor = CodeActualPriceProcessor()
__ths_l2_trade_queue_manager = trade_queue_manager.thsl2tradequeuemanager()
__thsBuy1VolumnManager = trade_queue_manager.THSBuy1VolumnManager()
@@ -596,9 +595,6 @@
return False
else:
l2_log.debug(code, "鍙互涓嬪崟锛屽師鍥狅細{}", reason)
- if code not in cls.__trade_thread_lock_dict:
- cls.__trade_thread_lock_dict[code] = threading.RLock()
- cls.__trade_thread_lock_dict[code].acquire()
try:
l2_log.debug(code, "寮�濮嬫墽琛屼拱鍏�")
trade_manager.start_buy(code, capture_timestamp, last_data,
@@ -619,7 +615,7 @@
pass
finally:
# l2_log.debug(code, "m鍊煎奖鍝嶅洜瀛愶細{}", l2_trade_factor.L2TradeFactorUtil.factors_to_string(code))
- cls.__trade_thread_lock_dict[code].release()
+ pass
return True
# 鏄惁鍙互鍙栨秷
@@ -919,11 +915,7 @@
@classmethod
def __cancel_buy(cls, code):
- # 鍔犻攣
- if code not in cls.__trade_thread_lock_dict:
- cls.__trade_thread_lock_dict[code] = threading.RLock()
try:
- cls.__trade_thread_lock_dict[code].acquire()
l2_log.debug(code, "寮�濮嬫墽琛屾挙鍗�")
trade_manager.start_cancel_buy(code)
l2_log.debug(code, "鎵ц鎾ゅ崟鎴愬姛")
@@ -933,7 +925,7 @@
l2_log.debug(code, "鎵ц鎾ゅ崟寮傚父锛歿}", str(e))
return False
finally:
- cls.__trade_thread_lock_dict[code].release()
+ pass
@classmethod
--
Gitblit v1.8.0