From 3b435873873d5cd498086d9f6afaef3af758a856 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期三, 13 九月 2023 23:28:51 +0800
Subject: [PATCH] H撤重新定义
---
main.py | 18 ++++++++++--------
1 files changed, 10 insertions(+), 8 deletions(-)
diff --git a/main.py b/main.py
index 02e897b..2223e0e 100644
--- a/main.py
+++ b/main.py
@@ -34,7 +34,8 @@
t1.start()
#
# 浜ゆ槗鎺ュ彛鏈嶅姟
- t1 = threading.Thread(target=trade_api_server.run, name="trade_api_server", args=(pipe_server, pipe_l2), daemon=True)
+ t1 = threading.Thread(target=trade_api_server.run, name="trade_api_server", args=(pipe_server, pipe_l2),
+ daemon=True)
t1.start()
#
# redis鍚庡彴鏈嶅姟
@@ -42,18 +43,18 @@
t1.start()
#
# 鍚姩L2璁㈤槄鏈嶅姟
- t1 = threading.Thread(target=huaxin_client.l2_client.run, name="l2_client", args=(ptl2_l2, psl2_l2, trade_server.my_l2_data_callback),
+ t1 = threading.Thread(target=huaxin_client.l2_client.run, name="l2_client",
+ args=(ptl2_l2, psl2_l2, trade_server.my_l2_data_callback),
daemon=True)
t1.start()
#
# 鍚姩鍗庨懌浜ゆ槗鏈嶅姟
- t1 = threading.Thread(target=huaxin_client.trade_client.run, name="trade_client",
- args=(trade_server.my_trade_response, ptl2_trade, pst_trade),
- daemon=True)
+ t1 = threading.Thread(
+ target=lambda: trade_server.run(pipe_trade, pipe_l1, pipe_l2, huaxin_client.trade_client.process_cmd),
+ name="trade_server", daemon=True)
t1.start()
- # 浜ゆ槗鏈嶅姟
- trade_server.run(pipe_trade, pipe_l1, pipe_l2, huaxin_client.trade_client.process_cmd)
+ huaxin_client.trade_client.run(trade_server.my_trade_response, ptl2_trade, pst_trade)
# 涓绘湇鍔�
@@ -106,7 +107,8 @@
l1Process.start()
# 涓昏繘绋�
- createTradeServer(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy, ptl2_l2, psl2_l2, ptl2_trade, pst_trade)
+ createTradeServer(pss_strategy, pst_strategy, pl1t_strategy, psl2_strategy, ptl2_l2, psl2_l2, ptl2_trade,
+ pst_trade)
# 灏唗radeServer浣滀负涓昏繘绋�
l1Process.join()
--
Gitblit v1.8.0