From 4ee1bd5de9ca76a69adac6e17a11bd686c742ef3 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 22 五月 2024 18:57:54 +0800
Subject: [PATCH] 融入交易
---
main.py | 20 ++++++++++++++++++--
1 files changed, 18 insertions(+), 2 deletions(-)
diff --git a/main.py b/main.py
index bc90c4b..b98d5a8 100644
--- a/main.py
+++ b/main.py
@@ -1,18 +1,23 @@
+import multiprocessing
import threading
import constant
import data_server
-import log
import middle_api_server
import middle_cb_api_server
import middle_server
+# from huaxin_client import huaxin_trade_client
+# from trade import huaxin_trade_api
+# from huaxin_client import huaxin_trade_client
+from log_module import async_log_util
+# from trade import huaxin_trade_api
if __name__ == "__main__":
t1 = threading.Thread(target=lambda: middle_api_server.run(), daemon=True)
t1.start()
t1 = threading.Thread(target=lambda: data_server.run("0.0.0.0", constant.DATA_SERVER_PORT), daemon=True)
t1.start()
- t1 = threading.Thread(target=lambda: log.async_log_util.run_sync(), daemon=True)
+ t1 = threading.Thread(target=lambda: async_log_util.run_sync(), daemon=True)
t1.start()
t1 = threading.Thread(target=lambda: middle_server.run(12880), daemon=True)
t1.start()
@@ -21,4 +26,15 @@
t1.start()
# t1 = threading.Thread(target=lambda: middle_l1_data_server.run(12881), daemon=True)
# t1.start()
+
+ # 杩愯浠跨湡浜ゆ槗
+ # queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query = multiprocessing.Queue(), multiprocessing.Queue(), multiprocessing.Queue()
+ # huaxin_trade_api.run_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query)
+
+ # ===========杩愯浜ゆ槗绔�==========
+ # tradeProcess = multiprocessing.Process(
+ # target=huaxin_trade_client.run,
+ # args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,))
+ # tradeProcess.start()
+
middle_server.run()
--
Gitblit v1.8.0