删除交易锁

Administrator

2023-09-06 99b593ee7062f66036ad72aef0cb3c5a3c9a7e2b

删除交易锁

 l2/cancel_buy_strategy.py

@@ -1090,7 +1090,7 @@
            MIN_MONEYS = [300, 200, 100, 50]
            for min_money in MIN_MONEYS:
                watch_indexes = set()
                for i in range(end_index - 1, start_index, -1):
                for i in range(end_index, start_index, -1):
                    data = total_datas[i]
                    val = data['val']
                    if not L2DataUtil.is_limit_up_price_buy(val):

 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