From 365491c1fcf523994035e4bd28d8b5872dd6ec98 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期四, 31 七月 2025 14:47:48 +0800
Subject: [PATCH] 除权采用掘金更新K线
---
main.py | 8 ++++----
1 files changed, 4 insertions(+), 4 deletions(-)
diff --git a/main.py b/main.py
index 431a1f2..e3bac57 100644
--- a/main.py
+++ b/main.py
@@ -84,8 +84,8 @@
channel_list = []
for i in range(constant.HUAXIN_L2_MAX_CODES_COUNT):
# 鍒涘缓濮旀墭/鎴愪氦鐨勫叡浜暟缁勫拰ZMQ閫氫俊閫氶亾
- delegate_ipc_addr = f"ipc://order_{i}.ipc",
- deal_ipc_addr = f"ipc://deal_{i}.ipc",
+ delegate_ipc_addr = f"ipc://order_{i}.ipc"
+ deal_ipc_addr = f"ipc://deal_{i}.ipc"
delegate = [0, shared_memery_util.create_array(), delegate_ipc_addr]
delegate[0] = shared_memery_util.get_number(delegate[1])
deal = [0, shared_memery_util.create_array(), deal_ipc_addr]
@@ -113,7 +113,7 @@
channels = channel_list[index:index + channel_count]
index += channel_count
# 璁㈤槄淇″彿闃熷垪, 鏁版嵁鍥炶皟闃熷垪锛堝洖璋冮娆″皬鐨勬暟鎹�氳繃杩欑鍥炶皟锛�
- sub_single_queue, data_callback_queue = multiprocessing.Queue(), multiprocessing.Queue()
+ sub_single_queue, data_callback_queue = multiprocessing.Queue(maxsize=1024), multiprocessing.Queue(maxsize=1024)
sub_single_queue_list.append(sub_single_queue)
data_callback_queue_list.append(data_callback_queue)
l2_process = multiprocessing.Process(target=l2_client_v2.run,
@@ -179,7 +179,7 @@
# 娴嬭瘯L2鍗曠嫭杩涚▼
- if True:
+ if constant.IS_L2_NEW:
__create_l2_subscript()
else:
# 灏哃2鐨勮繘绋嬫敼涓虹嚎绋嬫墽琛�
--
Gitblit v1.8.0