From 4e9aac4cf3b64c9547283c2a01826e5f3f7b28a1 Mon Sep 17 00:00:00 2001
From: Jerry Yan <792602257@qq.com>
Date: Sat, 29 Nov 2025 12:41:17 +0800
Subject: [PATCH] =?UTF-8?q?chore(threadpool):=20=E8=B0=83=E6=95=B4?=
 =?UTF-8?q?=E4=BA=BA=E8=84=B8=E8=AF=86=E5=88=AB=E7=BA=BF=E7=A8=8B=E6=B1=A0?=
 =?UTF-8?q?=E9=85=8D=E7=BD=AE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

- 将核心线程数从32增加到128
- 将最大线程数从128增加到256
- 将空闲线程存活时间从60秒减少到10秒
- 将任务队列容量从1000调整为1024
---
 .../config/FaceRecognitionThreadPoolConfig.java      | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/ycwl/basic/integration/kafka/config/FaceRecognitionThreadPoolConfig.java b/src/main/java/com/ycwl/basic/integration/kafka/config/FaceRecognitionThreadPoolConfig.java
index 7f2d8b41..06d20672 100644
--- a/src/main/java/com/ycwl/basic/integration/kafka/config/FaceRecognitionThreadPoolConfig.java
+++ b/src/main/java/com/ycwl/basic/integration/kafka/config/FaceRecognitionThreadPoolConfig.java
@@ -19,19 +19,19 @@ public class FaceRecognitionThreadPoolConfig {
 
     /**
      * 创建人脸识别专用线程池
-     * - 核心线程数：32
-     * - 最大线程数：128
+     * - 核心线程数：128
+     * - 最大线程数：256
      * - 队列容量：1000（避免无限制增长）
      * - 拒绝策略：CallerRunsPolicy（调用者线程执行）
      */
     @Bean(name = "faceRecognitionExecutor", destroyMethod = "shutdown")
     public ThreadPoolExecutor faceRecognitionExecutor() {
         ThreadPoolExecutor executor = new ThreadPoolExecutor(
-            32,                                      // 核心线程数
-            128,                                     // 最大线程数
-            60L,                                     // 空闲线程存活时间
+            128,                                     // 核心线程数
+            256,                                     // 最大线程数
+            10L,                                     // 空闲线程存活时间
             TimeUnit.SECONDS,                        // 时间单位
-            new LinkedBlockingQueue<>(1000),         // 任务队列
+            new LinkedBlockingQueue<>(1024),         // 任务队列
             r -> {
                 Thread thread = new Thread(r);
                 thread.setName("face-recognition-" + thread.getId());