Spring Boot中关闭的ScheduledExecutorService Bean如何重新实例化

默认Spring单例Bean在整个应用上下文生命周期内只会创建一次，强行动态替换单例实例会导致其他已注入该Bean的组件持有旧引用，出现调用已关闭执行器的问题，不建议这么做。你可以从以下两种成熟方案里选：

方案1：基于动态代理实现透明替换（推荐，无需修改现有业务注入逻辑） #

这个方案对外暴露的Bean实例始终是同一个代理对象，内部自动维护真实的执行器引用，检测到执行器关闭、且需要调用执行能力时自动重建新实例，所有注入点无需任何修改就能自动拿到可用的执行器。
配置代码如下：

@Configuration
public class ExecutorConfiguration {
    @Value("${scheduler.jobs}")
    private Integer jobCorePoolSize;

    @Bean
    public ScheduledExecutorService jobExecutor() {
        return (ScheduledExecutorService) Proxy.newProxyInstance(
                ScheduledExecutorService.class.getClassLoader(),
                new Class[]{ScheduledExecutorService.class},
                new ExecutorInvocationHandler()
        );
    }

    private class ExecutorInvocationHandler implements InvocationHandler {
        private volatile ScheduledExecutorService targetExecutor;

        @Override
        public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
            // 单独处理isShutdown判断：已有实例时直接返回真实状态，不触发重建
            if ("isShutdown".equals(method.getName()) && targetExecutor != null) {
                return method.invoke(targetExecutor, args);
            }
            // 首次调用、或检测到执行器已关闭时，重建实例
            if (targetExecutor == null || targetExecutor.isShutdown()) {
                synchronized (this) {
                    if (targetExecutor == null || targetExecutor.isShutdown()) {
                        targetExecutor = Executors.newScheduledThreadPool(jobCorePoolSize);
                    }
                }
            }
            return method.invoke(targetExecutor, args);
        }
    }
}

这个方案的优势：

• 原有所有@Autowired ScheduledExecutorService的业务代码完全不需要改动
• 双重检查锁+volatile保证多线程场景下的线程安全，不会出现重复创建实例、拿到已关闭实例的问题
• 执行器的创建逻辑统一收敛在配置类，和你原来的使用习惯一致

方案2：手动维护实例（适合逻辑简单的轻量场景） #

如果不想引入动态代理，也可以自己做一个持有类作为Spring Bean管理，内部维护真实的执行器实例：

@Component
public class JobExecutorProvider {
    @Value("${scheduler.jobs}")
    private Integer jobCorePoolSize;
    private volatile ScheduledExecutorService executor;

    /**
     * 每次获取执行器时自动检查状态，已关闭则重建
     */
    public ScheduledExecutorService getExecutor() {
        if (executor == null || executor.isShutdown()) {
            synchronized (this) {
                if (executor == null || executor.isShutdown()) {
                    executor = Executors.newScheduledThreadPool(jobCorePoolSize);
                }
            }
        }
        return executor;
    }

    /**
     * 对外提供关闭方法，和你现有的用户触发关闭逻辑对接
     */
    public void shutdownCurrentExecutor() {
        if (executor != null && !executor.isShutdown()) {
            executor.shutdown();
        }
    }
}

这个方案的缺点是需要修改原有业务代码，把直接注入ScheduledExecutorService改成注入JobExecutorProvider，再调用getExecutor()拿到可用实例，优点是逻辑直白，没有代理层的理解成本。

避坑提醒：不要尝试通过DefaultListableBeanFactory动态销毁、重新注册同名单例Bean的方式实现替换，这种方式无法更新其他Bean中已经注入的旧执行器引用，会出现随机调用已关闭实例的问题，还会打乱Spring上下文的Bean生命周期状态。

内容的提问来源于stack exchange，提问作者ahrooran