测试

Administrator

2024-11-21 264b292269847a39d9553872941eb77ada5cdb2f

测试

 main.py

@@ -144,10 +144,10 @@
            queue_other_w_l2_r, huaxin_trade_server.my_l2_data_callbacks), daemon=True).start()

        # 绑核运行
        psutil.Process(l1Process.pid).cpu_affinity([20])
        psutil.Process(tradeProcess.pid).cpu_affinity([21, 22])
        cpu_indexes = [i for i in range(23, 30)]
        psutil.Process(os.getpid()).cpu_affinity(cpu_indexes)
        # psutil.Process(l1Process.pid).cpu_affinity([20])
        # psutil.Process(tradeProcess.pid).cpu_affinity([21, 22])
        # cpu_indexes = [i for i in range(23, 30)]
        # psutil.Process(os.getpid()).cpu_affinity(cpu_indexes)
        # 主进程
        createTradeServer(pss_strategy, queue_strategy_r_trade_w, queue_l1_w_strategy_r, queue_strategy_w_trade_r,
                          queue_strategy_w_trade_r_for_read, queue_l1_trade_r_strategy_w,

 servers/huaxin_trade_server.py

@@ -395,7 +395,8 @@
        cls.__save_l1_current_price(datas)
        cls.__process_buy_open_limit_up_datas(datas)
        # 9:30之前采用非线程
        if int(tool.get_now_time_str().replace(":", "")) < int("093000"):
        # TODO 测试
        if int(tool.get_now_time_str().replace(":", "")) < int("093000") or True:
            HuaXinL1TargetCodesManager.set_level_1_codes_datas(datas, request_id=request_id)
        else:
            cls.__process_l1_data_thread_pool.submit(