From dcb8ca6aebca9cef3672c007438f3f459988a921 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 15 十一月 2023 12:37:51 +0800
Subject: [PATCH] 交易查询分离
---
main.py | 10 +++++++---
1 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/main.py b/main.py
index 59cfa40..9e57f96 100644
--- a/main.py
+++ b/main.py
@@ -24,7 +24,8 @@
def createTradeServer(pipe_server, queue_strategy_r_trade_w_: multiprocessing.Queue,
queue_l1_w_strategy_r_: multiprocessing.Queue,
- queue_strategy_w_trade_r_: multiprocessing.Queue, order_queues_, transaction_queues_,
+ queue_strategy_w_trade_r_: multiprocessing.Queue,
+ queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, order_queues_, transaction_queues_,
market_queue_):
logger_system.info("绛栫暐杩涚▼ID锛歿}", os.getpid())
log.close_print()
@@ -46,7 +47,7 @@
t1.start()
#
# 鍚姩鍗庨懌浜ゆ槗鏈嶅姟
- huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_, order_queues_,
+ huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_, queue_strategy_w_trade_r_for_read_, order_queues_,
transaction_queues_, market_queue_)
@@ -92,6 +93,7 @@
# 浜ゆ槗璇荤瓥鐣ュ啓
queue_strategy_w_trade_r = multiprocessing.Queue()
+ queue_strategy_w_trade_r_for_read = multiprocessing.Queue()
# 绛栫暐璇讳氦鏄撳啓
queue_strategy_r_trade_w = multiprocessing.Queue()
@@ -107,7 +109,8 @@
# 浜ゆ槗杩涚▼
tradeProcess = multiprocessing.Process(
target=huaxin_client.trade_client.run,
- args=(None, queue_other_w_l2_r, queue_strategy_r_trade_w, queue_strategy_w_trade_r,))
+ args=(None, queue_other_w_l2_r, queue_strategy_r_trade_w, queue_strategy_w_trade_r,
+ queue_strategy_w_trade_r_for_read))
tradeProcess.start()
# 鍒涘缓L2閫氫俊闃熷垪
@@ -127,6 +130,7 @@
# 涓昏繘绋�
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,
order_queues, transaction_queues, market_queue)
# 灏唗radeServer浣滀负涓昏繘绋�
--
Gitblit v1.8.0