From af7d9b55cad79aa7ade0b02802a26ebeb742c297 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 28 三月 2024 16:08:46 +0800
Subject: [PATCH] 持仓L2订阅
---
main.py | 12 ++++++++++--
1 files changed, 10 insertions(+), 2 deletions(-)
diff --git a/main.py b/main.py
index 318c450..93cacdd 100644
--- a/main.py
+++ b/main.py
@@ -1,6 +1,7 @@
import multiprocessing
+import threading
-from huaxin_client import l1_client_for_trade, trade_client
+from huaxin_client import l1_client_for_trade, trade_client, l2_client
from trade import trade_strategy
import huaxin_client
@@ -13,6 +14,8 @@
# 绛栫暐璇讳氦鏄撳啓
queue_strategy_r_trade_w = multiprocessing.Queue()
+ queue_strategy_w_l2_r = multiprocessing.Queue()
+
# 鍚姩L1
l1TradeProcess = multiprocessing.Process(target=l1_client_for_trade.run,
args=(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w,))
@@ -24,4 +27,9 @@
target=trade_client.run,
args=(queue_strategy_r_trade_w, queue_strategy_w_trade_r))
tradeProcess.start()
- trade_strategy.run(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w, queue_strategy_r_trade_w, queue_strategy_w_trade_r)
+
+ trade_strategy.init_l2_data_callbacks()
+ threading.Thread(target=lambda: l2_client.run(queue_strategy_w_l2_r, trade_strategy.l2_data_callbacks),
+ daemon=True).start()
+ trade_strategy.run(queue_l1_trade_w_strategy_r, queue_l1_trade_r_strategy_w, queue_strategy_r_trade_w,
+ queue_strategy_w_trade_r,queue_strategy_w_l2_r)
--
Gitblit v1.8.0