++++++++++++++++ 取消不必要的并行计算框架

Administrator

2023-08-16 965bd2fea182851382f61d9c7c1492d04546bf4d

 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)

            # 已被并行处理
            # # 记录买入信号位置