From ba4833a0c8bd76f63efff1e55e59a3b5765134bf Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 11 三月 2025 14:48:48 +0800
Subject: [PATCH] 测试L2
---
main.py | 17 +++++++++--------
1 files changed, 9 insertions(+), 8 deletions(-)
diff --git a/main.py b/main.py
index 6f762ee..431a1f2 100644
--- a/main.py
+++ b/main.py
@@ -176,14 +176,15 @@
queue_strategy_w_trade_r_for_read))
tradeProcess.start()
# 姝ゅ灏哃2鐨勮繘绋嬩笌绛栫暐杩涚▼鍚堝苟
- # L2
- # l2Process = multiprocessing.Process(
- # target=huaxin_client.l2_client.run,
- # args=(queue_other_w_l2_r, order_queues, transaction_queues, market_queue, order_ipc_hosts,huaxin_trade_server.my_l2_data_callback))
- # l2Process.start()
- # 灏哃2鐨勮繘绋嬫敼涓虹嚎绋嬫墽琛�
- threading.Thread(target=huaxin_client.l2_client.run, args=(
- queue_other_w_l2_r, huaxin_trade_server.my_l2_data_callbacks), daemon=True).start()
+
+ # 娴嬭瘯L2鍗曠嫭杩涚▼
+
+ if True:
+ __create_l2_subscript()
+ else:
+ # 灏哃2鐨勮繘绋嬫敼涓虹嚎绋嬫墽琛�
+ threading.Thread(target=huaxin_client.l2_client.run, args=(
+ queue_other_w_l2_r, huaxin_trade_server.my_l2_data_callbacks), daemon=True).start()
# 杩愯鍗庨懌澧炲�兼湇鍔¤繘绋�
threading.Thread(target=hx_qc_value_util.run, daemon=True).start()
--
Gitblit v1.8.0