主线程取消绑核运行

Administrator

2024-11-21 3c697d1ca40366059df3dc2e994ccf90f2c3ec98

主线程取消绑核运行

 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_api_server.py

@@ -519,9 +519,8 @@
    logger_system.info(f"trade_api_server 线程ID:{tool.get_thread_id()}")
    # 拉取交易信息
    huaxin_trade_data_update.run(queue_l1_trade_r_strategy_w, queue_other_w_l2_r)
    # TODO 测试注释掉
    # t1 = threading.Thread(target=lambda: __set_target_codes(queue_other_w_l2_r), daemon=True)
    # t1.start()
    t1 = threading.Thread(target=lambda: __set_target_codes(queue_other_w_l2_r), daemon=True)
    t1.start()

    t1 = threading.Thread(target=lambda: __read_sync_task(pipe_server), daemon=True)
    t1.start()