From 3e862b6bbbb6146c7938f71bf026178e3e40e973 Mon Sep 17 00:00:00 2001
From: ObjectNotFound <zhouweitong@huawei.com>
Date: Tue, 9 Dec 2025 21:33:04 +0800
Subject: [PATCH] =?UTF-8?q?=E7=A7=BB=E9=99=A4ProcessHandler=E9=99=90?=
 =?UTF-8?q?=E5=88=B6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 apps/common/process_handler.py | 6 ------
 1 file changed, 6 deletions(-)

diff --git a/apps/common/process_handler.py b/apps/common/process_handler.py
index b4bddf2c..9a6b5426 100644
--- a/apps/common/process_handler.py
+++ b/apps/common/process_handler.py
@@ -21,8 +21,6 @@ class ProcessHandler:
     """存储进程的字典"""
     lock = multiprocessing.Lock()
     """锁对象"""
-    max_processes = max((os.cpu_count() or 1) // 2, 1)
-    """最大进程数"""
     timeout = 5
     """超时时间"""
     @staticmethod
@@ -63,10 +61,6 @@ class ProcessHandler:
             logger.warning("[ProcessHandler] 获取任务ID时锁超时。")
             return False
         logger.info("[ProcessHandler] 添加任务 %s", task_id)
-        if len(ProcessHandler.tasks) >= ProcessHandler.max_processes:
-            logger.warning("[ProcessHandler] 任务数量已达上限(%s)，请稍后再试。", ProcessHandler.max_processes)
-            ProcessHandler.lock.release()
-            return False
         try:
             if task_id not in ProcessHandler.tasks:
                 process = mp.Process(
-- 
Gitee