init

utils.py

@@ -4,6 +4,7 @@ import os
 import re
 import shutil
 import threading
+from concurrent.futures import ThreadPoolExecutor, as_completed
 from typing import Optional
 
 import cv2
@@ -253,11 +254,10 @@ def ensure_bos_resources(force_download: bool = False) -> bool:
             _BOS_DOWNLOAD_COMPLETED = True
             return True
 
-        results = []
+        download_jobs = []
         for target in targets:
             if not isinstance(target, dict):
                 logger.warning("无效的 BOS 下载配置项: %r", target)
-                results.append(False)
                 continue
 
             prefix = target.get("bos_prefix")
@@ -266,16 +266,57 @@ def ensure_bos_resources(force_download: bool = False) -> bool:
 
             if not prefix or not destination:
                 logger.warning("缺少必要字段，无法处理 BOS 下载配置: %r", target)
-                results.append(False)
                 continue
 
-            logger.info("准备同步 BOS 资源: %s (prefix=%s -> %s)", description, prefix, destination)
-            success = download_bos_directory(prefix, destination, force_download=force_download)
-            if success:
-                logger.info("BOS 资源已就绪: %s", description)
-            else:
-                logger.warning("BOS 资源同步失败: %s", description)
-            results.append(success)
+            download_jobs.append(
+                {
+                    "description": description,
+                    "prefix": prefix,
+                    "destination": destination,
+                }
+            )
+
+        if not download_jobs:
+            logger.info("未找到有效的 BOS 下载目标，跳过资源同步")
+            _BOS_DOWNLOAD_COMPLETED = True
+            return True
+
+        results = []
+        max_workers = min(len(download_jobs), max(os.cpu_count() or 1, 1))
+        if max_workers <= 0:
+            max_workers = 1
+
+        with ThreadPoolExecutor(max_workers=max_workers, thread_name_prefix="bos-sync") as executor:
+            future_to_job = {}
+            for job in download_jobs:
+                logger.info(
+                    "准备同步 BOS 资源: %s (prefix=%s -> %s)",
+                    job["description"],
+                    job["prefix"],
+                    job["destination"],
+                )
+                future = executor.submit(
+                    download_bos_directory,
+                    job["prefix"],
+                    job["destination"],
+                    force_download=force_download,
+                )
+                future_to_job[future] = job
+
+            for future in as_completed(future_to_job):
+                job = future_to_job[future]
+                description = job["description"]
+                try:
+                    success = future.result()
+                except Exception as exc:
+                    logger.warning("BOS 资源同步异常: %s (%s)", description, exc)
+                    success = False
+
+                if success:
+                    logger.info("BOS 资源已就绪: %s", description)
+                else:
+                    logger.warning("BOS 资源同步失败: %s", description)
+                results.append(success)
 
         all_ready = all(results) if results else True
         if all_ready: