CountDownLatch和CyclicBarrier你使用过吗?-阿里云开发者社区

CountDownLatch和CyclicBarrier你使用过吗?

2024-01-24 25

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： CountDownLatch和CyclicBarrier你使用过吗?

1 CountDownLatch

1.1 含义

一种同步辅助，允许一个或多个线程等待一组正在其他线程中执行的操作完成。CountDownLatch使用给定的计数进行初始化。由于对countDown方法的调用，await方法会阻塞，直到当前计数为零，在此之后，所有正在等待的线程都会被释放，后续对await的调用会立即返回。这是一种一次性现象——计数无法重置。如果需要重置计数的版本，可以考虑使用CyclicBarrier。

CountDownLatch是一个通用的同步工具，可以用于许多目的。初始化计数为1的CountDownLatch作为一个简单的打开/关闭锁:所有调用await的线程都在门上等待，直到它被调用countDown的线程打开。初始化为N的CountDownLatch可以用来让一个线程等待，直到N个线程完成某个动作，或者某个动作已经完成N次。

CountDownLatch的一个有用属性是，它不要求调用countDown的线程等待计数达到0后再继续，它只是阻止任何线程通过await，直到所有线程都可以通过。

1.2 使用场景举例

公司要选择一个办公室开董事会，董事会共有股东十个人，需要等每个股东都要到办公室才能开会，我们把每个股东视为一个线程，把开会这个事件视为主线程。

1.3 代码实现

/**
 * @desc: JUC CountDownLatch应用场景
 * @author: YanMingXin
 * @create: 2021/7/31-10:24
 **/
public class Test01 {
    public static void main(String[] args) throws InterruptedException {
        //公司开会需要集齐董事会10个人，10个人不分先后，只要来齐了才能开会
        CountDownLatch latch = new CountDownLatch(10);
        //十个人每个人一个线程
        for (int i = 0; i <= 10; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName() + "到场");
                //增加一个人
                latch.countDown();
            }, String.valueOf(i)).start();
        }
        //主线程等待
        latch.await();
        System.out.println("开始开会......");
    }
}

测试结果

2 CyclicBarrier

2.1 含义

一种同步辅助，它允许一组线程都等待彼此到达一个共同的障碍点。CyclicBarrier在涉及固定大小的线程的程序中非常有用，这些线程偶尔必须相互等待。这个屏障被称为循环屏障，因为在等待的线程被释放后，它可以被重用。

CyclicBarrier支持一个可选的Runnable命令，该命令在每个barrier点运行一次，在该组的最后一个线程到达之后，但在任何线程被释放之前。这个barrier操作对于在任何一方继续之前更新共享状态非常有用。

2.2 使用场景举例

公司开完董事会后，为了保证安全性需要将办公室锁起来，当然锁门之前需要每个人都要走出来，我们仍旧把每个人当作一个线程，把锁门的事件当做主线程。

2.3 代码实现

/**
 * @desc: JUC CyclicBarrier
 * @author: YanMingXin
 * @create: 2021/7/31-10:31
 **/
public class Test02 {
    public static void main(String[] args) {
        //公司董事会开完会要等全部出去才能锁门
        CyclicBarrier barrier = new CyclicBarrier(10, () -> {
            System.out.println("办公室锁门......");
        });
        for (int i = 1; i <= 10; i++) {
            new Thread(() -> {
                System.out.println(Thread.currentThread().getName());
                try {
                    //等待锁门
                    barrier.await();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }, String.valueOf(i)).start();
        }
    }
}

测试结果：

3 结语

当然以上的使用场景是最常见的，以后有时间的话还要研究下CountDownLatch和CyclicBarrier的其他使用场景和原理，敬请期待哦！