Web应用关闭后ScheduledThreadPoolExecutor未终止，如何停止其运行？

问题根源 #

你创建的ScheduledExecutorService默认持有非守护线程，该类线程不会随浏览器关闭、用户登出这类前端操作销毁，只有Web应用本身停止/卸载时主动触发终止逻辑，才能停止对应的定时任务。

方案1：原生Servlet环境（无框架） #

用ServletContextListener监听Web应用的生命周期，在应用销毁时终止线程池：

• 第一步：将线程池实例定义为全局可访问，可存入ServletContext或静态变量
• 第二步：实现ServletContextListener，代码示例如下：

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.annotation.WebListener;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

@WebListener
public class ExecutorShutdownListener implements ServletContextListener {
    @Override
    public void contextInitialized(ServletContextEvent sce) {
        // 应用启动时初始化线程池，完成任务注册逻辑
        ScheduledExecutorService executor = Executors.newScheduledThreadPool(0);
        Runnable task = () -> {
            // 检查数据库连接状态并记录日志结果
        };
        executor.scheduleWithFixedDelay(task, 0, 10, TimeUnit.MINUTES);
        // 将线程池存入ServletContext
        sce.getServletContext().setAttribute("dbCheckExecutor", executor);
    }

    @Override
    public void contextDestroyed(ServletContextEvent sce) {
        ScheduledExecutorService executor = (ScheduledExecutorService) sce.getServletContext().getAttribute("dbCheckExecutor");
        if (executor != null) {
            executor.shutdown();
            try {
                // 等待现有任务最多30秒完成
                if (!executor.awaitTermination(30, TimeUnit.SECONDS)) {
                    // 超时强制终止所有任务
                    executor.shutdownNow();
                }
            } catch (InterruptedException e) {
                // 中断时强制终止
                executor.shutdownNow();
                Thread.currentThread().interrupt();
            }
        }
    }
}

如果不用@WebListener注解，也可以在web.xml里配置：

<listener>
    <listener-class>com.yourpackage.ExecutorShutdownListener</listener-class>
</listener>

方案2：Spring/SpringBoot环境 #

Spring框架自带Bean生命周期管理，有两种简单实现方式：

方式1：注册线程池为Bean，指定销毁方法 #

@Configuration
public class ExecutorConfig {
    @Bean(destroyMethod = "shutdown")
    public ScheduledExecutorService dbCheckExecutor() {
        ScheduledExecutorService executor = Executors.newScheduledThreadPool(0);
        Runnable task = () -> {
            // 检查数据库连接状态并记录日志结果
        };
        executor.scheduleWithFixedDelay(task, 0, 10, TimeUnit.MINUTES);
        return executor;
    }
}

Spring会在容器销毁时自动调用指定的shutdown方法终止线程池。

方式2：用@PreDestroy注解手动处理 #

如果你的线程池是在业务类里初始化的，可以在销毁方法上加@PreDestroy注解：

@Component
public class DbCheckService {
    private ScheduledExecutorService executor;

    // 类初始化时启动任务
    public DbCheckService() {
        executor = Executors.newScheduledThreadPool(0);
        Runnable task = () -> {
            // 检查数据库连接状态并记录日志结果
        };
        executor.scheduleWithFixedDelay(task, 0, 10, TimeUnit.MINUTES);
    }

    // 容器销毁前自动执行该方法
    @PreDestroy
    public void shutdownExecutor() {
        if (executor != null) {
            executor.shutdown();
            try {
                if (!executor.awaitTermination(30, TimeUnit.SECONDS)) {
                    executor.shutdownNow();
                }
            } catch (InterruptedException e) {
                executor.shutdownNow();
                Thread.currentThread().interrupt();
            }
        }
    }
}

补充说明 #

• 关闭浏览器、用户登出属于前端客户端操作，和服务端线程生命周期完全无关，因此不会触发线程池终止，只有Web应用停止、卸载、服务进程关闭时才会执行上述销毁逻辑。
• 如果需要用户登出时就停止该用户专属的定时任务，你需要将线程池/任务和用户会话绑定，监听HttpSessionListener的会话销毁事件来终止对应任务，这种场景注意不要每个用户都创建独立线程池，避免资源耗尽。

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