diff --git a/app/chain/mediaserver.py b/app/chain/mediaserver.py index 89b40cec..8b9a5186 100644 --- a/app/chain/mediaserver.py +++ b/app/chain/mediaserver.py @@ -3,6 +3,7 @@ from typing import List, Union, Optional, Generator from app import schemas from app.chain import ChainBase +from app.core.config import global_vars from app.db.mediaserver_oper import MediaServerOper from app.helper.service import ServiceConfigHelper from app.log import logger @@ -134,6 +135,8 @@ class MediaServerChain(ChainBase): logger.info(f"正在同步 {server_name} 媒体库 {library.name} ...") library_count = 0 for item in self.items(server=server_name, library_id=library.id): + if global_vars.is_system_stopped: + return if not item or not item.item_id: continue logger.debug(f"正在同步 {item.title} ...") diff --git a/app/core/event.py b/app/core/event.py index 43ea8f7c..f04d2c2a 100644 --- a/app/core/event.py +++ b/app/core/event.py @@ -20,7 +20,7 @@ from app.utils.singleton import Singleton DEFAULT_EVENT_PRIORITY = 10 # 事件的默认优先级 MIN_EVENT_CONSUMER_THREADS = 1 # 最小事件消费者线程数 INITIAL_EVENT_QUEUE_IDLE_TIMEOUT_SECONDS = 1 # 事件队列空闲时的初始超时时间(秒) -MAX_EVENT_QUEUE_IDLE_TIMEOUT_SECONDS = 60 # 事件队列空闲时的最大超时时间(秒) +MAX_EVENT_QUEUE_IDLE_TIMEOUT_SECONDS = 5 # 事件队列空闲时的最大超时时间(秒) class Event: