requirements update16

app.py

@@ -5,6 +5,7 @@ import os
 import sys
 from pathlib import Path
 import concurrent.futures
+import multiprocessing  # 添加multiprocessing模块以获取CPU核心数
 
 # 添加当前目录和src目录到模块搜索路径
 current_dir = os.path.dirname(os.path.abspath(__file__))
@@ -29,8 +30,10 @@ def evaluate(input_data):
             return {"status": "Exception", "error": "Input must be a list"}
             
         results = []
-        # 使用线程池并行处理多个测试用例
-        with concurrent.futures.ThreadPoolExecutor() as executor:
+        # 获取CPU核心数作为最大线程数
+        max_workers = multiprocessing.cpu_count()
+        # 使用线程池并行处理多个测试用例，限制最大线程数为CPU核心数
+        with concurrent.futures.ThreadPoolExecutor(max_workers=max_workers) as executor:
             # 提交所有任务到线程池
             future_to_item = {executor.submit(evaluate_single_case, item): item for item in input_data}
             # 获取结果