Java对线程池做监控的实现方法

import java.util.concurrent.ThreadPoolExecutor;  
  
public class MonitoredThreadPoolExecutor extends ThreadPoolExecutor {  
  
    public MonitoredThreadPoolExecutor(int corePoolSize, int maximumPoolSize,  
                                      long keepAliveTime, java.util.concurrent.TimeUnit unit,  
                                      java.util.concurrent.BlockingQueue<Runnable> workQueue) {  
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);  
    }  
  
    // 获取当前线程池状态信息  
    public String getStatusInfo() {  
        StringBuilder sb = new StringBuilder();  
        sb.append("ThreadPool Status: ").append(isShutdown() ? "SHUTDOWN" : "RUNNING").append("\n");  
        sb.append("  Core Pool Size: ").append(getCorePoolSize()).append("\n");  
        sb.append("  Max Pool Size: ").append(getMaximumPoolSize()).append("\n");  
        sb.append("  Active Threads: ").append(getActiveCount()).append("\n");  
        sb.append("  Task Queue Size: ").append(getQueue().size()).append("\n");  
        sb.append("  Completed Tasks: ").append(getCompletedTaskCount()).append("\n");  
        sb.append("  Rejected Tasks: ").append(getRejectedExecutionCount()).append("\n");  
        return sb.toString();  
    }  
  
    // 其他监控方法可以根据需要添加  
    // ...  
}

import java.util.concurrent.LinkedBlockingQueue;  
  
public class ThreadPoolMonitorExample {  
    public static void main(String[] args) {  
        // 创建一个线程池，使用MonitoredThreadPoolExecutor  
        MonitoredThreadPoolExecutor executor = new MonitoredThreadPoolExecutor(  
                5, 10, 60L, java.util.concurrent.TimeUnit.SECONDS,  
                new LinkedBlockingQueue<Runnable>());  
  
        // 提交任务到线程池...  
        // executor.execute(...);  
  
        // 在需要的时候获取线程池状态信息  
        System.out.println(executor.getStatusInfo());  
  
        // 关闭线程池（通常在应用程序关闭时）  
        // executor.shutdown();  
    }  
}