背景

前面我们举了一个例子，说明 CountDownLatch 闭锁的运用，本文我们讲解一下 CyclicBarrier 的运用，这两个经常被面试官放在一起问区别，实际上记住和理解我举的这两个例子就基本掌握了它们的区别。

CyclicBarrier （栅栏）

CyclicBarrier 类似于闭锁，与闭锁的关键区别在于，闭锁用于等待事件(上次我们的例子中，主线程等待其他 cache 加载完成才继续执行，没加载完成就阻塞主线程)，栅栏用于等待其他线程，其作用是让一组线程到达一个屏障时被阻塞，直到最后一个线程到达屏障时，屏障才会开门，所有被屏障拦截的线程才会继续运行。CountDownLatch 倾向于一个线程等多个线程，CyclicBarrier 倾向于多个线程互相等待。

栅栏的作用就类似于运动员赛跑时候的发令枪，裁判没打发令枪之前，谁也不准跑

应用：性能测试

考虑这么一个问题，现在要对你们线上的数据库做压测。你可能想到这么几步：

搭建和线上一样配置的机子；
模拟线上数据；
进行读写测试；
调整读写请求的比例进行测试；
观察 I/O、MEM、CPU 等指标；
观察主从节点备份情况。

第 2 步准备数据的是时候，你起了 1w 个线程去准备数据，但是 load 数据是需要时间的，这个时候如果有的线程先请求了数据库，有的线程后请求数据库，对于数据库的 QPS 就是 < 1w 的，所以需要他们同时并发的去请求。在 load 数据这个阶段我们用 CyclicBarrier 去拦住他们，当所有的线程都 load 好数据之后，同时请求数据库，对数据库进行压测。

public class CyclicBarrierTest { private static CyclicBarrier cyclicBarrier; public static class PrepareReadDataThread extends Thread { private int id; PrepareReadDataThread(int id) { this.id = id; } public void run() { try { System.out.println("线程：" + this.id + " 可以读数据啦!"); cyclicBarrier.await(); } catch (Exception e) { e.printStackTrace(); } System.out.println("所有任务完毕，继续处理其他任务... "+System.currentTimeMillis()); } } public static class PrepareWriteDataThread extends Thread { private int id; PrepareWriteDataThread(int id) { this.id = id; } public void run() { try { Thread.sleep(3000); System.out.println("线程：" + this.id + " 可以 load 写数据完成!"); cyclicBarrier.await(); } catch (Exception e) { e.printStackTrace(); } System.out.println("所有任务完毕，继续处理其他任务... "+System.currentTimeMillis()); } } public static void main(String[] args) { cyclicBarrier = new CyclicBarrier(5, () -> System.out.println("测试开始!")); for (int i = 0; i < 5; i++) { new PrepareReadDataThread(i).start(); } //重置一下 cyclicBarrier.reset(); for (int i = 0; i < 5; i++) { new PrepareWriteDataThread(i).start(); } } }

对比

1.CountDownLatch 的计数器只能使用一次，而 CyclicBarrier 的计数器可以使用 reset()方法重置。所以 CyclicBarrier 能处理更为复杂的业务场景。例如，如果计算发生错误，可以重置计数器，并让线程重新执行一次

2.CyclicBarrier 还提供其他有用的方法，比如 getNumberWaiting 方法可以获得 Cyclic-Barrier 阻塞的线程数量。isBroken()方法用来了解阻塞的线程是否被中断

3.CountDownLatch 倾向于一个线程等多个线程，CyclicBarrier 倾向于多个线程互相等待

[ Java ] CyclicBarrier 在性能测试中的运用

背景

CyclicBarrier （栅栏）

应用：性能测试

对比

相关阅读