Servlet中如何关闭ScheduledExecutorService创建的父子线程？

这个问题问得很到位！我来给你拆解清楚：

1. 调用父线程池的shutdownNow()不会终止子线程 #

每个ScheduledExecutorService都是独立的线程池实例，它们之间没有层级关联。父线程池的shutdownNow()只会终止它自己管理的线程，而子线程是由另一个独立的ScheduledExecutorService创建和管理的，父线程池根本“管不到”这些子线程。所以直接调用父线程池的shutdownNow()，子线程池会继续运行，子线程也不会被终止。

2. 在contextDestroyed中终止所有线程的解决方案 #

要彻底终止所有父、子线程，你需要：

• 保存所有创建的ScheduledExecutorService实例（包括父和所有子线程池）
• 在Servlet销毁时，依次调用每个线程池的shutdownNow()，并等待线程池终止
• 确保任务代码能正确响应中断信号

具体实现示例 #

第一步：保存所有线程池实例

在Servlet类中定义成员变量，存储父线程池和所有子线程池（用线程安全的集合避免并发问题）：

import java.util.concurrent.CopyOnWriteArrayList;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

public class MyServletContextListener implements ServletContextListener {
    private ScheduledExecutorService parentExecutor;
    private CopyOnWriteArrayList<ScheduledExecutorService> childExecutors = new CopyOnWriteArrayList<>();

第二步：初始化线程池（contextInitialized方法）

创建父线程池，在父线程任务中创建子线程池并加入集合：

@Override
    public void contextInitialized(ServletContextEvent sce) {
        // 创建父线程池
        parentExecutor = Executors.newSingleThreadScheduledExecutor();
        // 父线程以固定速率轮询
        parentExecutor.scheduleAtFixedRate(() -> {
            // 创建子线程池
            ScheduledExecutorService childExecutor = Executors.newSingleThreadScheduledExecutor();
            childExecutors.add(childExecutor);
            // 子线程以固定速率运行
            childExecutor.scheduleAtFixedRate(() -> {
                // 任务逻辑中必须检查中断状态，响应终止信号
                if (Thread.currentThread().isInterrupted()) {
                    System.out.println("子线程收到中断信号，即将退出");
                    return;
                }
                // 执行你的业务逻辑
                System.out.println("子线程正在执行任务");
            }, 0, 10, TimeUnit.SECONDS);
        }, 0, 60, TimeUnit.SECONDS);
    }

第三步：销毁所有线程池（contextDestroyed方法）

依次终止所有子线程池，再终止父线程池，同时等待线程池完成终止：

@Override
    public void contextDestroyed(ServletContextEvent sce) {
        // 先终止所有子线程池
        for (ScheduledExecutorService childExecutor : childExecutors) {
            if (!childExecutor.isShutdown()) {
                childExecutor.shutdownNow();
                try {
                    // 等待5秒让线程池终止，超时则记录日志
                    if (!childExecutor.awaitTermination(5, TimeUnit.SECONDS)) {
                        System.err.println("子线程池未能在规定时间内终止");
                    }
                } catch (InterruptedException e) {
                    // 恢复中断状态
                    Thread.currentThread().interrupt();
                }
            }
        }

        // 再终止父线程池
        if (parentExecutor != null && !parentExecutor.isShutdown()) {
            parentExecutor.shutdownNow();
            try {
                if (!parentExecutor.awaitTermination(5, TimeUnit.SECONDS)) {
                    System.err.println("父线程池未能在规定时间内终止");
                }
            } catch (InterruptedException e) {
                Thread.currentThread().interrupt();
            }
        }
    }
}

关键注意点 #

• 任务必须响应中断：shutdownNow()只是给线程发送中断信号，如果你的任务代码不检查Thread.currentThread().isInterrupted()，也不处理InterruptedException，线程可能会继续运行，无法被终止。
• 线程安全的集合：因为父线程可能会多次创建子线程池，所以要用CopyOnWriteArrayList这种线程安全的集合来存储子线程池实例，避免并发修改问题。
• 终止顺序：建议先终止子线程池，再终止父线程池，避免父线程在销毁过程中又创建新的子线程池。

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