增加并行数量

admin

2025-04-08 70b51a2636858fb8cfbf39d3764d88d07286d8ad

 strategy/check_timer.py

@@ -1,15 +1,18 @@
"""
定义整个项目的定时器
"""
import datetime
# import datetime
import time
from strategy import data_cache

from log_module.log import logger_common
from strategy import data_cache, market_sentiment_analysis
from strategy import kpl_api
from strategy import instant_time_market
from strategy.logging_config import get_logger
from utils import tool

# from strategy import instant_time_market

# 获取logger实例
logger = get_logger()
logger = logger_common


# 构建一个项目整体的定时器对象
@@ -22,9 +25,9 @@
    while True:
        try:
            # 声明赋值实时时间
            now_time = datetime.datetime.now().strftime("%H:%M:%S")
            now_time = tool.get_now_time_str()
            # print(f"now_time==={now_time}")
            if now_time > data_cache.after_closing_time and data_cache.execution is False:
            if now_time > data_cache.AFTER_CLOSING_TIME and data_cache.execution is False:
                # 整理当日涨停信息并写入本地管理好本地数据
                kpl_api.get_arrange_limit_up_info()
                logger.info(f"整理当日涨停信息 已经运行完成")
@@ -33,6 +36,13 @@
                logger.info(f"获取所有个股的板块概念 已经运行完成")
                # 完成了后将是否执行的开个标记为真
                data_cache.execution = True
            # 本地数据更新时间
            if data_cache.UPDATE_DATA_TIME < now_time and data_cache.index_K_line_write_execution is False:
                # 写入所有指数K线
                market_sentiment_analysis.all_index_k_line_dict_write()
                logger.info(f"写入所有带属性指数K线 已经运行完成")
                # 完成了后将是否执行的开个标记为真
                data_cache.index_K_line_write_execution = True
        except Exception as error:
            logger.error(f"实时检测定时器线程报错: {error}")
        finally: