并发编程之CountDownLatch和CyclicBarrier的详细解析(带小案例)

CountDownLatch

倒计时锁存器 用来解决线程执行次序的问题

• CountDownLatch主要有两个方法，当一个或多个线程调用await方法时，这些线程会阻塞。

• 其它线程调用countDown方法会将计数器减1(调用countDown方法的线程不会阻塞)，

• 当计数器的值变为o时，因await方法阻塞的线程会被唤醒，继续执行。

下面例子中，主线程‘班长’需要等子线程全部执行完成再执行，但是出现了如下情况：

运行结果：

代码：

public class CountDownLatchDemo {
    public static void main(String[] args) {
        for (int i = 0; i < 6; i++) {
            new Thread(()->{
                System.out.println("离开了教室");
            },i+"").start();
        }
​
        System.out.println("班长关门走人");
    }
}

​

解决方法：使用CountDownLatch

运行结果：

代码：

public class CountDownLatchDemo {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(6);
        for (int i = 0; i < 6; i++) {
            new Thread(()->{
                System.out.println("离开了教室");
                countDownLatch.countDown();
            },i+"").start();
        }
        countDownLatch.await();
        System.out.println("班长关门走人");
​
    }
}

CyclicBarrier

---------------------(循环屏障)

和上面的CountDownLatch（做减法倒计时开始任务）不同，CyclicBarrier是做加法来开始任务的

运行结果：

代码：

​

public class CyclicBarrierDemo {
    public static void main(String[] args) {
        CyclicBarrier cyclicBarrier = new CyclicBarrier(7, ()->{
            System.out.println("召唤神龙");
        });
​
        for (int i = 0; i < 7; i++) {
            int temp = i;
            new Thread(()->{
                try {
                    System.out.println("集齐第"+temp+"颗龙珠");
                    cyclicBarrier.await();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            },i+"").start();
        }
    }
}