From cb8227fef858f06290fea302f2c13a055695ca05 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 12 三月 2024 14:35:35 +0800
Subject: [PATCH] L2订单数据接收方式修改
---
l2/l2_data_listen_manager.py | 10 +++++-----
1 files changed, 5 insertions(+), 5 deletions(-)
diff --git a/l2/l2_data_listen_manager.py b/l2/l2_data_listen_manager.py
index b425a75..1f0a19f 100644
--- a/l2/l2_data_listen_manager.py
+++ b/l2/l2_data_listen_manager.py
@@ -129,18 +129,18 @@
threading.Thread(target=lambda: self.__create_ipc_server(host), daemon=True).start()
# 鎺ユ敹L2鏁版嵁
- def receive_l2_data(self, order_queues, transaction_queues, market_queue, order_ipc_hosts):
+ def receive_l2_data(self, order_queues, transaction_queues, market_queue):
# TODO 鏆傛椂涓嶉�氳繃闃熷垪鎺ユ敹鏁版嵁
- # for q in order_queues:
- # t1 = threading.Thread(target=lambda: self.__recive_l2_orders(q), daemon=True)
- # t1.start()
+ for q in order_queues:
+ t1 = threading.Thread(target=lambda: self.__recive_l2_orders(q), daemon=True)
+ t1.start()
for q in transaction_queues:
t2 = threading.Thread(target=lambda: self.__recive_transaction_orders(q), daemon=True)
t2.start()
t3 = threading.Thread(target=lambda: self.__recive_l2_markets(market_queue), daemon=True)
t3.start()
# 鎺ユ敹璁㈠崟hosts
- self.__create_ipc_server_hosts(order_ipc_hosts)
+ # self.__create_ipc_server_hosts(order_ipc_hosts)
def get_active_count(self, type_):
expire_time = time.time() - 5
--
Gitblit v1.8.0