From 2240a8d4774635edd58a2cddbd4e835ebdfacdb3 Mon Sep 17 00:00:00 2001
From: zren25 <zhen.ren.2@volvocars.com>
Date: Tue, 27 May 2025 20:06:34 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E7=BA=BF=E7=A8=8B=E6=B1=A0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/volvo/ai/analytic/center/config/ExecutorConfig.java  | 5 ++---
 1 file changed, 2 insertions(+), 3 deletions(-)

diff --git a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java
index 1623eed..ddb1c60 100644
--- a/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java
+++ b/ai-analytic-center-biz/src/main/java/com/volvo/ai/analytic/center/config/ExecutorConfig.java
@@ -30,7 +30,7 @@ public class ExecutorConfig {
     @Bean("threadPoolTaskExecutor")
     @Primary
     public ThreadPoolTaskExecutor corpusProcessExecutor() {
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+        executor = new ThreadPoolTaskExecutor();
         executor.setCorePoolSize(corePoolSize);
         executor.setMaxPoolSize(maxPoolSize);
         executor.setQueueCapacity(queueCapacity);
@@ -38,14 +38,13 @@ public class ExecutorConfig {
         executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
         executor.setKeepAliveSeconds(keepAliveSeconds);
         executor.initialize();
-        this.executor = executor;
         return executor;
     }
 
     @PreDestroy
     public void destroy() {
         if (executor != null) {
-            log.info("Shutting down thread pool: {}", executor);
+            log.info("Thread-process-pool-ShuttingDown: {}", executor);
             ThreadPoolExecutor threadPoolExecutor = this.executor.getThreadPoolExecutor();
             threadPoolExecutor.shutdownNow(); // 强制关闭所有正在执行的任务
         }