From 588d0e9644e8aa3ad9f6b83b973da852e4ceb662 Mon Sep 17 00:00:00 2001
From: Administrator <admin@example.com>
Date: 星期一, 04 十二月 2023 14:28:08 +0800
Subject: [PATCH] bug修改
---
huaxin_client/l2_client.py | 10 ++++++----
1 files changed, 6 insertions(+), 4 deletions(-)
diff --git a/huaxin_client/l2_client.py b/huaxin_client/l2_client.py
index 4439f92..f863935 100644
--- a/huaxin_client/l2_client.py
+++ b/huaxin_client/l2_client.py
@@ -122,11 +122,12 @@
result = self.__api.SubscribeMarketData(sz, lev2mdapi.TORA_TSTP_EXD_SZSE)
logger_local_huaxin_l2_subscript.info(f"甯傚満璁㈤槄缁撴灉sz锛歿result}")
- def __process_codes_data(self, codes_data, from_cache=False):
+ def __process_codes_data(self, codes_data, from_cache=False, delay=0):
if not self.is_login and not constant.TEST:
raise Exception("L2灏氭湭鐧诲綍")
-
+ if delay > 0:
+ time.sleep(delay)
codes = set()
for d in codes_data:
code = d[0]
@@ -212,8 +213,9 @@
print("----L2琛屾儏鐧诲綍鎴愬姛----")
self.is_login = True
# 鍒濆璁剧疆鍊�
- t1 = threading.Thread(target=lambda: self.__process_codes_data(self.__get_latest_datas(), from_cache=True),
- daemon=True)
+ t1 = threading.Thread(
+ target=lambda: self.__process_codes_data(self.__get_latest_datas(), from_cache=True, delay=6),
+ daemon=True)
# 鍚庡彴杩愯
t1.start()
--
Gitblit v1.8.0