ExecutorService如何监控状态

在 Java 中，ExecutorService 本身没有直接提供完整的运行时监控 API，但可以通过 标准接口 + 自定义扩展 + 外部工具 来监控其状态。下面从 常用手段 → 代码示例 → 高级方案 系统说明。

一、通过 ExecutorService 自身 API 监控（基础）

1️⃣ 核心可获取信息

ExecutorService executor = Executors.newFixedThreadPool(10);

可获取的状态：

• isShutdown()：是否已调用 shutdown
• isTerminated()：是否完全结束
• awaitTermination(timeout)：等待结束

executor.isShutdown();
executor.isTerminated();

❌ 缺点：
拿不到线程数、队列长度、活跃线程数

二、使用 ThreadPoolExecutor（推荐 ✅）

ExecutorService 的常用实现是 ThreadPoolExecutor，它提供丰富监控方法。

1️⃣ 创建可监控线程池

ThreadPoolExecutor executor = new ThreadPoolExecutor(
        10,
        20,
        60L,
        TimeUnit.SECONDS,
        new LinkedBlockingQueue<>(100)
);

2️⃣ 常用监控指标

示例：定时打印状态

ScheduledExecutorService monitor = Executors.newSingleThreadScheduledExecutor();

monitor.scheduleAtFixedRate(() -> {
    System.out.println("poolSize=" + executor.getPoolSize());
    System.out.println("activeCount=" + executor.getActiveCount());
    System.out.println("queueSize=" + executor.getQueue().size());
    System.out.println("completed=" + executor.getCompletedTaskCount());
}, 0, 5, TimeUnit.SECONDS);

三、使用 beforeExecute / afterExecute（任务级监控）

适合统计：

• 单个任务耗时
• 异常监控
• 成功率

public class MonitorThreadPool extends ThreadPoolExecutor {

    public MonitorThreadPool(int core, int max, long keepAlive, TimeUnit unit, BlockingQueue<Runnable> queue) {
        super(core, max, keepAlive, unit, queue);
    }

    @Override
    protected void beforeExecute(Thread t, Runnable r) {
        System.out.println("任务开始: " + r);
    }

    @Override
    protected void afterExecute(Runnable r, Throwable t) {
        System.out.println("任务结束");
    }
}

四、结合 JMX 监控（生产推荐 ✅✅）

1️⃣ 暴露 MBean

ManagementFactory.getPlatformMBeanServer()
    .registerMBean(executor, new ObjectName("threadpool:name=myPool"));

2️⃣ 使用工具查看

• JConsole
• VisualVM
• Prometheus + JMX Exporter

五、Micrometer / Prometheus（最专业）

ThreadPoolExecutor executor = ...
ExecutorServiceMetrics.monitor(meterRegistry, executor, "my-executor");

可监控：

• 活跃线程
• 队列大小
• 任务执行时间
• 拒绝次数

六、监控线程池“拒绝任务”

new ThreadPoolExecutor(..., new RejectedExecutionHandler() {
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
        System.out.println("任务被拒绝");
    }
});

七、总结对比

如果你愿意，我可以：

• ✅ 给你一个完整可运行监控 Demo
• ✅ 设计Spring Boot 线程池监控方案
• ✅ 对比 Tomcat / Netty 线程池监控

你现在是 普通 Java 项目还是 Spring Boot？