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());