Java线程池监控与管理技巧分享

ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);
ThreadPoolExecutor executor = (ThreadPoolExecutor) yourExecutorService;

scheduler.scheduleAtFixedRate(() -> {
    System.out.println("Pool Size: " + executor.getPoolSize());
    System.out.println("Active Threads: " + executor.getActiveCount());
    System.out.println("Completed Tasks: " + executor.getCompletedTaskCount());
    System.out.println("Queued Tasks: " + executor.getQueue().size());
}, 0, 5, TimeUnit.SECONDS);

class MonitoredThreadPool extends ThreadPoolExecutor {
    public MonitoredThreadPool(int corePoolSize, int maximumPoolSize,
                               long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue) {
        super(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue);
    }

    protected void beforeExecute(Thread t, Runnable r) {
        System.out.println("Task " + r + " starting on thread " + t.getName());
    }

    protected void afterExecute(Runnable r, Throwable ex) {
        if (ex != null) {
            System.err.println("Task " + r + " threw exception: " + ex);
        }
        System.out.println("Task " + r + " finished");
    }
}