From 77ec4416fe199d6e41a0b49934f636d488f445a8 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期二, 21 五月 2024 18:12:42 +0800
Subject: [PATCH] bug修复
---
main.py | 6 +++---
1 files changed, 3 insertions(+), 3 deletions(-)
diff --git a/main.py b/main.py
index de8df0d..b500601 100644
--- a/main.py
+++ b/main.py
@@ -192,15 +192,15 @@
# ===========杩愯浜ゆ槗澶栭儴API==========
# 绛栫暐涓庝氦鏄撻�氫俊闃熷垪
# 浜ゆ槗缁撴灉璇诲彇, 浜ゆ槗鍛戒护闃熷垪涓庝氦鏄撴煡璇㈤槦鍒楄缃负鍚屼竴涓�
- queue_strategy_r_trade_w, queue_strategy_w_trade_r = multiprocessing.Queue(), multiprocessing.Queue()
- huaxin_trade_api.run_trade(queue_strategy_r_trade_w, queue_strategy_w_trade_r, queue_strategy_w_trade_r)
+ 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_r_trade_w,))
+ args=(queue_strategy_w_trade_r, queue_strategy_w_trade_r_for_query, queue_strategy_r_trade_w,))
tradeProcess.start()
# ===========杩愯鏈湴API鎺ュ彛==========
--
Gitblit v1.8.0