From 25cf95a04cdd13485620206a6ae34e8b18642a05 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 31 一月 2024 14:59:54 +0800
Subject: [PATCH] L1交易订阅修改
---
main.py | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/main.py b/main.py
index 7688f1a..5c66386 100644
--- a/main.py
+++ b/main.py
@@ -29,7 +29,7 @@
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):
+ market_queue_, queue_l1_trade_r_strategy_w_, queue_l1_trade_w_strategy_r_):
logger_system.info("绛栫暐杩涚▼ID锛歿}", os.getpid())
log.close_print()
# 鍒濆鍖栧弬鏁�
@@ -41,7 +41,7 @@
#
# 浜ゆ槗鎺ュ彛鏈嶅姟
t1 = threading.Thread(target=huaxin_trade_api_server.run, name="trade_api_server",
- args=(pipe_server, queue_other_w_l2_r, queue_l1_trade_r_strategy_w),
+ args=(pipe_server, queue_other_w_l2_r, queue_l1_trade_r_strategy_w_),
daemon=True)
t1.start()
#
@@ -53,7 +53,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_l1_trade_w_strategy_r)
+ queue_l1_trade_w_strategy_r_)
# 涓绘湇鍔�
--
Gitblit v1.8.0