From 1fdd45034464e00df842c06a5d6c5988e4ebb8e1 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 19 十一月 2024 11:16:42 +0800
Subject: [PATCH] 策略进程绑核运行

---
 main.py |   15 ++++++++++++---
 1 files changed, 12 insertions(+), 3 deletions(-)

diff --git a/main.py b/main.py
index 1b08351..34dbb35 100644
--- a/main.py
+++ b/main.py
@@ -1,6 +1,8 @@
 """
 GUI绠$悊
 """
+import psutil
+
 from code_attribute import gpcode_manager
 from log_module import log
 from log_module.log import logger_l2_trade, logger_system
@@ -61,8 +63,6 @@
     t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop, name="redis", daemon=True)
     t1.start()
 
-
-
     #
     # 鍚姩鍗庨懌浜ゆ槗鏈嶅姟
     huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_,
@@ -87,6 +87,7 @@
     huaxin_client.l2_client.test()
 
 if __name__ == '__main__':
+    # 鍙粦瀹�16-31涔嬮棿鐨勬牳
     try:
         logger_l2_trade.info("鍚姩绋嬪簭")
         logger_system.info("鍚姩绋嬪簭--------")
@@ -145,10 +146,18 @@
         threading.Thread(target=huaxin_client.l2_client.run, args=(
             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)
         # 涓昏繘绋�
         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,
-                          queue_l1_trade_w_strategy_r, (order_ipc_addr, cancel_order_ipc_addr), queue_custom_block_in_money)
+                          queue_l1_trade_w_strategy_r, (order_ipc_addr, cancel_order_ipc_addr),
+                          queue_custom_block_in_money)
+
+
 
         # 灏唗radeServer浣滀负涓昏繘绋�
         l1Process.join()

--
Gitblit v1.8.0