From 5c5a34e67334e53e3ac9da5adc85ccc8ec0529c4 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 18 三月 2024 15:58:19 +0800
Subject: [PATCH] 删除多余的策略-L2的通信方式
---
main.py | 22 ++++------------------
1 files changed, 4 insertions(+), 18 deletions(-)
diff --git a/main.py b/main.py
index f73fdc2..f8ff4b5 100644
--- a/main.py
+++ b/main.py
@@ -28,8 +28,7 @@
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,
- queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, order_queues_, transaction_queues_,
- market_queue_, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_):
+ queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_):
logger_system.info("绛栫暐杩涚▼ID锛歿}", os.getpid())
log.close_print()
# 鍒濆鍖栧弬鏁�
@@ -51,8 +50,7 @@
#
# 鍚姩鍗庨懌浜ゆ槗鏈嶅姟
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_,
+ queue_strategy_w_trade_r_for_read_,
queue_l1_trade_w_strategy_r_)
@@ -127,16 +125,6 @@
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閫氫俊闃熷垪
- order_queues = []
- transaction_queues = []
- market_queue = multiprocessing.Queue()
- for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT):
- order_queues.append(multiprocessing.Queue())
- for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT):
- transaction_queues.append(multiprocessing.Queue())
-
# 姝ゅ灏哃2鐨勮繘绋嬩笌绛栫暐杩涚▼鍚堝苟
# L2
# l2Process = multiprocessing.Process(
@@ -145,13 +133,11 @@
# l2Process.start()
# 灏哃2鐨勮繘绋嬫敼涓鸿繘绋嬫墽琛�
threading.Thread(target=huaxin_client.l2_client.run, args=(
- queue_other_w_l2_r, order_queues, transaction_queues, market_queue,
- huaxin_trade_server.my_l2_data_callbacks), daemon=True).start()
+ queue_other_w_l2_r, huaxin_trade_server.my_l2_data_callbacks), daemon=True).start()
# 涓昏繘绋�
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, queue_l1_trade_r_strategy_w,
+ queue_strategy_w_trade_r_for_read, queue_l1_trade_r_strategy_w,
queue_l1_trade_w_strategy_r)
# 灏唗radeServer浣滀负涓昏繘绋�
--
Gitblit v1.8.0