Java多線程之監控Java線程池運行狀態

如果你想監控某一個線程池的執行狀態，線程池執行類 ThreadPoolExecutor 也給出了相關的 API, 能實時獲取線程池的當前活動線程數、正在排隊中的線程數、已經執行完成的線程數、總線程數等。

總線程數 = 排隊線程數 + 活動線程數 + 執行完成的線程數。

public class ThreadCount {
    private static ExecutorService executorService = new ThreadPoolExecutor(50,
            100,0L, TimeUnit.MILLISECONDS,
            new LinkedBlockingDeque<Runnable>(100000));

    public static void main(String[] args) throws Exception {
        for (int i = 0; i < 100000; i++) {
            executorService.execute(()->{
                System.out.println(1);
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }
        ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor)executorService;
        while (true){
            System.out.println("--");
            int queueSize = threadPoolExecutor.getQueue().size();
            System.out.println("當前排隊線程數:"+queueSize);

            int activeCount = threadPoolExecutor.getActiveCount();
            System.out.println("當前活動線程數:"+activeCount);

            long completeTaskCount = threadPoolExecutor.getCompletedTaskCount();
            System.out.println("執行完成線程數:"+completeTaskCount);

            long taskCount = threadPoolExecutor.getTaskCount();
            System.out.println("總線程數:"+taskCount);

            Thread.sleep(3000);
        }
    }

}

線程池提交了 100000 個任務，但同時只有 50 個線程在執行工作，我們每隔 3 秒來獲取當前線程池的運行狀態。

第一次程序輸出：

總線程數（排隊線程數 + 活動線程數 +  執行完成線程數）：100000

第二次程序輸出：

總線程數（排隊線程數 + 活動線程數 +  執行完成線程數）：100000

活動線程數和總線程數是不變的，排隊中的線程數和執行完成的線程數不斷在變化，直到所有任務執行完畢，最后輸出：

總線程數（排隊線程數 + 活動線程數 +  執行完成線程數）：100000

這樣，你了解了這些 API 的使用方法，你想監控線程池的狀態就非常方便了。