From 3b6f1c1f7d7c42b16aec7af4403421a7a352e8ec Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 23 五月 2024 10:57:16 +0800
Subject: [PATCH] bug修复
---
main.py | 29 +++++++++++++++++------------
1 files changed, 17 insertions(+), 12 deletions(-)
diff --git a/main.py b/main.py
index 8b07885..961836a 100644
--- a/main.py
+++ b/main.py
@@ -227,19 +227,24 @@
trade_call_back_queue = multiprocessing.Queue()
- # ===========杩愯浜ゆ槗澶栭儴API==========
- # 绛栫暐涓庝氦鏄撻�氫俊闃熷垪
- # 浜ゆ槗缁撴灉璇诲彇, 浜ゆ槗鍛戒护闃熷垪涓庝氦鏄撴煡璇㈤槦鍒楄缃负鍚屼竴涓�
- 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)
# 鍗庨懌浜ゆ槗鏁版嵁鏇存柊
huaxin_trade_data_update.run()
-
- # ===========杩愯浜ゆ槗绔�==========
- tradeProcess = multiprocessing.Process(
- target=trade_client_for_cb.run,
- args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,))
- tradeProcess.start()
+ # 浠跨湡浜ゆ槗涓嶈繍琛屼氦鏄撳鎴风
+ # # ===========杩愯浜ゆ槗澶栭儴API==========
+ #
+ #
+ #
+ # # 绛栫暐涓庝氦鏄撻�氫俊闃熷垪
+ # # 浜ゆ槗缁撴灉璇诲彇, 浜ゆ槗鍛戒护闃熷垪涓庝氦鏄撴煡璇㈤槦鍒楄缃负鍚屼竴涓�
+ # 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=trade_client_for_cb.run,
+ # args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,))
+ # tradeProcess.start()
# ===========杩愯鏈湴API鎺ュ彛==========
# middle_api_protocol.SERVER_HOST = "192.168.3.122"
@@ -248,7 +253,7 @@
command_callback, [("trade_cb", 50)])
manager.run(blocking=False)
- threading.Thread(target=test, daemon=True).start()
+ # threading.Thread(target=test, daemon=True).start()
# ===========璇诲彇鏍规嵁L2鍒跺畾鐨勪拱鍏ョ瓥鐣�==========
threading.Thread(target=read_l2_results, args=(trade_call_back_queue,), daemon=True).start()
# ===========寮傛鏃ュ織鎸佷箙鍖�==========
--
Gitblit v1.8.0