一、问题背景在 Spring Boot 项目中我们经常会用到线程池来执行后台任务。但如果线程池没有正确关闭会导致进程无法退出、K8s 滚动更新超时等问题。先看一段代码Bean(destroyMethodshutdown)publicLockManagerlockManager(){returnnewLockManager();}这个destroyMethod shutdown到底做了什么为什么需要它二、destroyMethod 的作用2.1 Spring Bean 的生命周期启动 → 实例化 → 依赖注入 → 初始化 → 使用 → 销毁destroyMethod就是告诉 Spring容器关闭时调用这个 Bean 实例上的哪个方法来做资源清理。2.2 调用链路Spring 容器关闭 └─ 发现 Bean(destroyMethod shutdown) └─ 反射调用 instance.shutdown() ← 调用的是实例对象的方法 └─ 方法体内scheduler.shutdownNow() ← 你自己写的清理逻辑对应代码publicclassLockManager{privatefinalScheduledExecutorServiceschedulerExecutors.newSingleThreadScheduledExecutor();publicLockManager(){startCleanupTask();// 启动后台清理线程}// Spring 关闭时调用这个方法publicvoidshutdown(){scheduler.shutdownNow();// 关闭线程池}}2.3 关键区分名字来源作用lockManager()Bean 方法名Bean 的注册名工厂方法只调用一次shutdowndestroyMethod 属性Bean 实例上要调用的销毁方法名Spring 只负责找到并调用shutdown()不关心方法内部做什么。你在shutdown()里写什么它就执行什么。三、为什么线程池需要手动关闭3.1 核心原因非守护线程Executors工厂方法创建的线程池默认都是非守护线程// Executors.defaultThreadFactory() 源码publicThreadnewThread(Runnabler){ThreadtnewThread(group,r,namePrefixthreadNumber.getAndIncrement(),0);t.setDaemon(false);// ← 写死了非守护t.setPriority(Thread.NORM_PRIORITY);returnt;}线程类型JVM 行为守护线程daemontrueJVM 不等它直接退出非守护线程daemonfalseJVM 会等它执行完才退出 ← 默认是这个所有Executors工厂方法默认都是非守护线程方法默认 daemonnewSingleThreadScheduledExecutor()falsenewScheduledThreadPool(n)falsenewFixedThreadPool(n)falsenewCachedThreadPool()falsenewSingleThreadExecutor()false3.2 不关闭会怎样情况一正常关闭kill -15 / CtrlCJVM 收到信号 └─ Spring ShutdownHook 执行容器关闭 └─ 但 scheduler 线程还在跑非守护线程 └─ Spring 容器已关闭但 JVM 还在等这个线程 └─ 结果进程卡住几秒 → 超时后强制终止情况二代码中主动调用 context.close()main 方法执行完 └─ 但 scheduler 是非守护线程 └─ JVM 不退出进程挂住永远不返回情况三kill -9无论配不配destroyMethod都一样JVM 直接被杀什么都不执行3.3 实际生产影响影响项严重程度说明进程无法退出高嵌入式/单元测试场景下进程挂死关闭变慢中正常 kill 时多卡几秒资源泄漏中线程未释放端口/文件句柄未关闭K8s 滚动更新高旧 Pod 关不掉 → 超过 terminationGracePeriodSeconds → SIGKILL任务执行不完整低清理任务可能被中途打断四、项目中的三种关闭方式4.1 Bean(destroyMethod “shutdown”)适用于自定义 Bean 内部持有线程池ConfigurationpublicclassAppConfig{Bean(destroyMethodshutdown)publicLockManagerlockManager(){returnnewLockManager();}}publicclassLockManager{privatefinalScheduledExecutorServiceschedulerExecutors.newSingleThreadScheduledExecutor();publicLockManager(){startCleanupTask();}publicvoidshutdown(){scheduler.shutdownNow();}}4.2 PreDestroy 注解适用于Spring 组件Component内部持有线程池ComponentpublicclassDataToolMethod{privatefinalScheduledExecutorServiceschedulerExecutors.newSingleThreadScheduledExecutor();PostConstructpublicvoidinit(){scheduler.scheduleAtFixedRate(()-{// 定时刷新缓存},1,1,TimeUnit.MINUTES);}PreDestroypublicvoiddestroy(){if(scheduler!null!scheduler.isShutdown()){scheduler.shutdown();}}}4.3 finally 手动关闭适用于方法级线程池用完即关privateListReturnShoppingCardadd(...){ExecutorServiceexecutornull;try{executorExecutors.newSingleThreadExecutor();finalFuture?futureexecutor.submit(()-{// 业务逻辑});future.get(4400,TimeUnit.MILLISECONDS);}catch(Exceptione){future.cancel(true);}finally{executor.shutdown();// 用完即关}returnlist;}4.4 三种方式对比方式适用场景优点缺点destroyMethod自定义 Bean配置简单方法名写死在注解里PreDestroySpring 组件语义清晰需要单独写方法finally方法级线程池即时释放每次创建销毁有开销五、最佳实践5.1 优先使用 Spring 管理的线程池Spring 提供了ThreadPoolTaskExecutor自带优雅关闭不需要手动shutdown()ConfigurationEnableAsyncpublicclassAsyncConfig{Bean(taskExecutor)publicThreadPoolTaskExecutortaskExecutor(){ThreadPoolTaskExecutorexecutornewThreadPoolTaskExecutor();executor.setCorePoolSize(4);executor.setMaxPoolSize(8);executor.setQueueCapacity(100);executor.setThreadNamePrefix(task-);executor.setWaitForTasksToCompleteOnShutdown(true);// 等待任务完成executor.setAwaitTerminationSeconds(30);// 最多等30秒executor.initialize();returnexecutor;}}5.2 如果用原生 ExecutorService一定要关闭ComponentpublicclassMyService{privatefinalScheduledExecutorServiceschedulerExecutors.newSingleThreadScheduledExecutor();PreDestroypublicvoiddestroy(){scheduler.shutdown();// 停止接收新任务try{if(!scheduler.awaitTermination(10,TimeUnit.SECONDS)){scheduler.shutdownNow();// 强制停止}}catch(InterruptedExceptione){scheduler.shutdownNow();Thread.currentThread().interrupt();}}}5.3 方法级线程池不要每次都 new// ❌ 不推荐每次调用都创建销毁线程池publicvoidprocess(){ExecutorServiceexecutorExecutors.newSingleThreadExecutor();try{executor.submit(()-{...});}finally{executor.shutdown();}}// ✅ 推荐复用类级共享线程池ServicepublicclassMyService{privatefinalExecutorServiceexecutorExecutors.newSingleThreadExecutor();PreDestroypublicvoiddestroy(){executor.shutdown();}publicvoidprocess(){executor.submit(()-{...});}}六、总结问题答案destroyMethod 调用的是谁Bean 实例上的同名方法不是 Bean 工厂方法为什么需要手动关闭线程池Executors 默认创建非守护线程会阻止 JVM 退出不关闭有什么影响进程挂住、K8s 滚动更新超时、资源泄漏关闭线程池的三种方式destroyMethod、PreDestroy、finally最佳实践是什么优先用 Spring 的 ThreadPoolTaskExecutor自带优雅关闭