From b53b0f632cca75df8f39a17fab3d26caeecb2caf Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期五, 15 十一月 2024 18:44:23 +0800
Subject: [PATCH] 自定义板块净流入
---
main.py | 13 ++++++++++---
1 files changed, 10 insertions(+), 3 deletions(-)
diff --git a/main.py b/main.py
index 09d088d..1b08351 100644
--- a/main.py
+++ b/main.py
@@ -27,9 +27,10 @@
queue_l1_w_strategy_r_: multiprocessing.Queue,
queue_strategy_w_trade_r_: multiprocessing.Queue,
queue_strategy_w_trade_r_for_read_: multiprocessing.Queue, queue_l1_trade_r_strategy_w_,
- queue_l1_trade_w_strategy_r_, trade_ipc_addr):
+ queue_l1_trade_w_strategy_r_, trade_ipc_addr, queue_custom_block_in_money):
"""
绛栫暐杩涚▼
+
@param pipe_server:
@param queue_strategy_r_trade_w_:
@param queue_l1_w_strategy_r_:
@@ -38,6 +39,7 @@
@param queue_l1_trade_r_strategy_w_:
@param queue_l1_trade_w_strategy_r_:
@param trade_ipc_addr: 浜ゆ槗ipc鍦板潃(涓嬪崟鍦板潃, 鎾ゅ崟鍦板潃)
+ @param queue_custom_block_in_money: 鎺ユ敹鏉垮潡娴佸叆娴佸嚭
@return:
"""
logger_system.info("绛栫暐杩涚▼ID锛歿}", os.getpid())
@@ -58,11 +60,14 @@
# redis鍚庡彴鏈嶅姟
t1 = threading.Thread(target=redis_manager.RedisUtils.run_loop, name="redis", daemon=True)
t1.start()
+
+
+
#
# 鍚姩鍗庨懌浜ゆ槗鏈嶅姟
huaxin_trade_server.run(queue_strategy_r_trade_w_, queue_l1_w_strategy_r_, queue_strategy_w_trade_r_,
queue_strategy_w_trade_r_for_read_,
- queue_l1_trade_w_strategy_r_, trade_ipc_addr)
+ queue_l1_trade_w_strategy_r_, trade_ipc_addr, queue_custom_block_in_money)
# 涓绘湇鍔�
@@ -94,6 +99,7 @@
# l1
queue_l1_w_strategy_r = multiprocessing.Queue()
queue_l1_r_strategy_w = multiprocessing.Queue()
+ queue_custom_block_in_money = multiprocessing.Queue() # 鎺ユ敹鏉垮潡娴佸叆娴佸嚭
# l1浜ゆ槗
queue_l1_trade_w_strategy_r = multiprocessing.Queue()
queue_l1_trade_r_strategy_w = multiprocessing.Queue()
@@ -115,6 +121,7 @@
# L1璁㈤槄鏁版嵁
l1Process = multiprocessing.Process(target=huaxin_client.l1_client.run,
args=(queue_l1_w_strategy_r, queue_l1_r_strategy_w,
+ queue_custom_block_in_money,
gpcode_manager.BuyOpenLimitUpCodeManager().get_codes(),))
l1Process.start()
@@ -141,7 +148,7 @@
# 涓昏繘绋�
createTradeServer(pss_strategy, queue_strategy_r_trade_w, queue_l1_w_strategy_r, queue_strategy_w_trade_r,
queue_strategy_w_trade_r_for_read, queue_l1_trade_r_strategy_w,
- queue_l1_trade_w_strategy_r, (order_ipc_addr, cancel_order_ipc_addr))
+ queue_l1_trade_w_strategy_r, (order_ipc_addr, cancel_order_ipc_addr), queue_custom_block_in_money)
# 灏唗radeServer浣滀负涓昏繘绋�
l1Process.join()
--
Gitblit v1.8.0