From b51b2ae184fad5aaf37a78903987e064f192d430 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 26 五月 2025 11:35:20 +0800
Subject: [PATCH] 大单解析修改
---
third_data/hx_qc_value_util.py | 5 +++--
1 files changed, 3 insertions(+), 2 deletions(-)
diff --git a/third_data/hx_qc_value_util.py b/third_data/hx_qc_value_util.py
index f1d0e61..cfa2f3e 100644
--- a/third_data/hx_qc_value_util.py
+++ b/third_data/hx_qc_value_util.py
@@ -7,6 +7,7 @@
import time
from huaxin_client import l1_api_client
+from log_module.log import logger_debug
from utils import tool
__response_data = {}
@@ -144,7 +145,7 @@
def run():
global request_queue
- request_queue, response_queue = multiprocessing.Queue(), multiprocessing.Queue()
+ request_queue, response_queue = multiprocessing.Queue(maxsize=1024), multiprocessing.Queue(maxsize=1024)
# 鍚姩澧炲�兼湇鍔¤繘绋�
process = multiprocessing.Process(target=l1_api_client.run, args=(request_queue, response_queue,), daemon=True)
process.start()
@@ -153,7 +154,7 @@
def __test():
time.sleep(5)
- print( get_history_k_bars("000333", count=150))
+ print(get_history_k_bars("000333", count=150))
print(get_previous_trading_date("2024-12-31"))
print(get_next_trading_date("2024-12-30"))
--
Gitblit v1.8.0