public static void main(String[] args) throws InterruptedException {
        /**
         * 基于计数器的线程等待-完毕执行控制器
         * 线程A调用await()方法后, 只有计数为0, 线程A才能继续执行, 否则将一直挂起
         */
        CountDownLatch countDownLatch = new CountDownLatch(2);
        System.out.println("主线程开始执行");
        ExecutorService service1 = Executors.newSingleThreadExecutor();
        service1.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(3000);
                    System.out.println("子线程："+Thread.currentThread().getName()+"执行");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                /**
                 * 计数器的值减1
                 */
                countDownLatch.countDown();
            }
        });
        service1.shutdown();

        ExecutorService service2 = Executors.newSingleThreadExecutor();
        service2.execute(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(3000);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                /**
                 * 计数器的值减1
                 */
                System.out.println("子线程："+Thread.currentThread().getName()+"执行");
                countDownLatch.countDown();
            }
        });
        service2.shutdown();
        System.out.println("等待两个线程执行完毕…… ……");
        try {
            /**
             * 主线程里面调用的await()方法, 那么主线程在这里会被挂起,
             * 等到countDownLatch的计数为0的时候再继续回来执行
             */
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("两个子线程都执行完毕，继续执行主线程");
    }

打印如下:

主线程开始执行
等待两个线程执行完毕…… ……
子线程：pool-1-thread-1执行
子线程：pool-2-thread-1执行
两个子线程都执行完毕，继续执行主线程

赞赏

长按二维码向我转账

受苹果公司新规定影响，微信 iOS 版的赞赏功能被关闭，可通过二维码转账支持公众号。