import java.util.Random;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadPoolCompleted {
    public static void main(String[] args) {
        // 創(chuàng)建線程池
        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,
                0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));
        // 添加任務(wù)
        addTask(threadPool);
				// 打印結(jié)果
        System.out.println("線程池任務(wù)執(zhí)行完成！");
    }
    /**
     * 給線程池添加任務(wù)
     */
    private static void addTask(ThreadPoolExecutor threadPool) {
        // 任務(wù)總數(shù)
        final int taskCount = 5;
        // 添加任務(wù)
        for (int i = 0; i < taskCount; i++) {
            final int finalI = i;
            threadPool.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        // 隨機(jī)休眠 0-4s
                        int sleepTime = new Random().nextInt(5);
                        TimeUnit.SECONDS.sleep(sleepTime);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(String.format("任務(wù)%d執(zhí)行完成", finalI));
                }
            });
        }
    }
}

import java.util.Random;
import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
/**
 * 線程池任務(wù)執(zhí)行完成判斷
 */
public class ThreadPoolCompleted {
    public static void main(String[] args) {
        // 1.創(chuàng)建線程池
        ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,
                0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));
        // 2.添加任務(wù)
        addTask(threadPool);
        // 3.判斷線程池是否執(zhí)行完
        isCompleted(threadPool); // 【核心調(diào)用方法】
        // 4.線程池執(zhí)行完
        System.out.println();
        System.out.println("線程池任務(wù)執(zhí)行完成！");
    }

    /**
     * 方法1：isTerminated 實(shí)現(xiàn)方式
     * 判斷線程池的所有任務(wù)是否執(zhí)行完
     */
    private static void isCompleted(ThreadPoolExecutor threadPool) {
        threadPool.shutdown();
        while (!threadPool.isTerminated()) { // 如果沒有執(zhí)行完就一直循環(huán)
        }
    }

    /**
     * 給線程池添加任務(wù)
     */
    private static void addTask(ThreadPoolExecutor threadPool) {
        // 任務(wù)總數(shù)
        final int taskCount = 5;
        // 添加任務(wù)
        for (int i = 0; i < taskCount; i++) {
            final int finalI = i;
            threadPool.submit(new Runnable() {
                @Override
                public void run() {
                    try {
                        // 隨機(jī)休眠 0-4s
                        int sleepTime = new Random().nextInt(5);
                        TimeUnit.SECONDS.sleep(sleepTime);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(String.format("任務(wù)%d執(zhí)行完成", finalI));
                }
            });
        }
    }
}

/**
 * 方法2：getCompletedTaskCount 實(shí)現(xiàn)方式
 * 判斷線程池的所有任務(wù)是否執(zhí)行完
 */
private static void isCompletedByTaskCount(ThreadPoolExecutor threadPool) {
    while (threadPool.getTaskCount() != threadPool.getCompletedTaskCount()) {
    }
}

public static void main(String[] args) throws InterruptedException {
    // 創(chuàng)建線程池
    ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,
    	0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));
    final int taskCount = 5;    // 任務(wù)總數(shù)
    // 單次計(jì)數(shù)器
    CountDownLatch countDownLatch = new CountDownLatch(taskCount); // ①
    // 添加任務(wù)
    for (int i = 0; i < taskCount; i++) {
        final int finalI = i;
        threadPool.submit(new Runnable() {
            @Override
            public void run() {
                try {
                    // 隨機(jī)休眠 0-4s
                    int sleepTime = new Random().nextInt(5);
                    TimeUnit.SECONDS.sleep(sleepTime);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(String.format("任務(wù)%d執(zhí)行完成", finalI));
                // 線程執(zhí)行完，計(jì)數(shù)器 -1
                countDownLatch.countDown();  // ②
            }
        });
    }
    // 阻塞等待線程池任務(wù)執(zhí)行完
    countDownLatch.await();  // ③
    // 線程池執(zhí)行完
    System.out.println();
    System.out.println("線程池任務(wù)執(zhí)行完成！");
}

public static void main(String[] args) throws InterruptedException {
    // 創(chuàng)建線程池
    ThreadPoolExecutor threadPool = new ThreadPoolExecutor(10, 20,
    	0, TimeUnit.SECONDS, new LinkedBlockingDeque<>(1024));
    final int taskCount = 5;    // 任務(wù)總數(shù)
    // 循環(huán)計(jì)數(shù)器 ①
    CyclicBarrier cyclicBarrier = new CyclicBarrier(taskCount, new Runnable() {
        @Override
        public void run() {
            // 線程池執(zhí)行完
            System.out.println();
            System.out.println("線程池所有任務(wù)已執(zhí)行完！");
        }
    });
    // 添加任務(wù)
    for (int i = 0; i < taskCount; i++) {
        final int finalI = i;
        threadPool.submit(new Runnable() {
            @Override
            public void run() {
                try {
                    // 隨機(jī)休眠 0-4s
                    int sleepTime = new Random().nextInt(5);
                    TimeUnit.SECONDS.sleep(sleepTime);
                    System.out.println(String.format("任務(wù)%d執(zhí)行完成", finalI));
                    // 線程執(zhí)行完
                    cyclicBarrier.await(); // ②
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }
        });
    }
}