Java 21+Spring Boot中，检测特定结果时如何停止ExecutorService？

1. 修复依赖注入问题 #

你的stopPool方法未触发，核心原因大概率是SynchronisedCheckedMap中持有的SecurityCheck实例并非Spring管理的Bean。需要做到：

• 给SecurityCheck类添加@Service或@Component注解，让Spring接管实例的创建与管理
• 在SynchronisedCheckedMap中通过构造注入获取SecurityCheck实例，禁止手动new SecurityCheck()（手动创建的实例不受Spring管控，依赖注入会完全失效）

示例代码：

// SecurityCheck 标记为Spring服务类
@Service
public class SecurityCheck {
    private ExecutorService executor;

    // 初始化线程池（可通过@Value配置线程数等参数）
    public SecurityCheck() {
        this.executor = Executors.newFixedThreadPool(4);
    }

    // 批量启动检查任务
    public void startBatchCheck(List<YourRecord> records) {
        for (YourRecord record : records) {
            executor.submit(() -> runSingleCheck(record));
        }
    }

    private void runSingleCheck(YourRecord record) {
        Security security = new Security();
        int code = security.performCheck(record);
        if (code >= 800) {
            stopPool();
        }
    }

    public void stopPool() {
        // 后续补充终止逻辑
    }
}

// SynchronisedCheckedMap 通过构造注入获取SecurityCheck实例
@Component
public class SynchronisedCheckedMap {
    private final SecurityCheck securityCheck;

    // Spring自动注入SecurityCheck的Bean实例
    public SynchronisedCheckedMap(SecurityCheck securityCheck) {
        this.securityCheck = securityCheck;
    }

    // 触发线程池停止的方法
    public void triggerStop() {
        securityCheck.stopPool();
    }
}

2. 让shutdownNow真正生效：任务必须响应中断 #

shutdownNow()仅向线程发送中断信号，如果任务不处理中断，线程会持续运行。你需要在Security的检查逻辑中主动检测中断状态，或处理阻塞方法抛出的InterruptedException。

修改Security类的检查方法：

public class Security {
    public int performCheck(YourRecord record) {
        // 每次循环前检查是否被中断
        while (!Thread.currentThread().isInterrupted()) {
            // 执行单次检查逻辑
            int result = doCheckLogic(record);
            
            if (result >= 800) {
                return result;
            }

            // 处理阻塞操作的中断异常
            try {
                // 模拟检查间隔
                Thread.sleep(500);
            } catch (InterruptedException e) {
                // 重新设置中断状态，确保上层能感知
                Thread.currentThread().interrupt();
                // 终止任务并返回
                return -1;
            }
        }
        // 被中断时返回
        return -1;
    }

    private int doCheckLogic(YourRecord record) {
        // 替换为你的实际检查代码
        return new Random().nextInt(1000);
    }
}

3. 完善stopPool方法的终止逻辑 #

仅调用shutdownNow()不足以确保线程池终止，需配合等待逻辑并处理自身中断：

public void stopPool() {
    // 立即向所有任务发送中断信号
    executor.shutdownNow();
    
    try {
        // 等待线程池终止，设置超时避免无限等待
        if (!executor.awaitTermination(10, TimeUnit.SECONDS)) {
            System.err.println("线程池未能在指定时间内终止");
        }
    } catch (InterruptedException e) {
        // 重新设置当前线程的中断状态，不丢失信号
        Thread.currentThread().interrupt();
        // 再次尝试强制终止
        executor.shutdownNow();
    }
}

额外注意事项 #

• 若使用Spring的ThreadPoolTaskExecutor而非原生ExecutorService，需提前配置setWaitForTasksToCompleteOnShutdown(true)和setAwaitTerminationSeconds(10)，确保终止行为符合预期
• 避免用全局变量传递终止信号，优先依赖线程池的中断机制，可靠性更高
• 检查任务中是否存在未处理的阻塞操作（如数据库连接等待、网络请求），这类操作若不响应中断，需手动关闭资源后退出任务

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