Broken BarrierException

2024-04-29 09:06:46 CyclicBarrier主要用来控制线程的执行速率，初始化时指定线程数，线程调用await()方法时会阻塞，直到到达的线程数等于初始线程数，才会放行，并且一起执行。与CountDownLatch区别是，CyclicBarrier可以循环执行，而CountDownLatch只能执行一次。 引言 CyclicBarrier中文叫做循环栅栏，用来控制线程的执行速率。 适用场景：一组线程在到达栅栏之前，需要相互等待，到达栅栏之后（满足了特定条件），再一起执行。 适用场景好像跟CountDownLatch一样，前面介绍过CountDownLatch的适用场景，跟第二种场景很像，不过还是有点区别： CountDownLatch需要手动调用countDown()方法，这组线程才能一起执行，而CyclicBarrier无需调用调用任何方法，线程会自动执行。 CountDownLatch只能使用一次，而CyclicBarrier可以循环使用。 再提一下CountDownLatch的两个适用场景： 当前线程等待其他线程都执行完成之后，再执行。...

写在开头 面试官：同学，AQS的原理知道吗？ 我：学过一点，抽象队列同步器，Java中很多同步工具都是基于它的... 面试官：好的，那其中CyclicBarrier学过吗？讲一讲它的妙用吧 我：啊，这个，这个我平时写代码没用过...

CyclicBarrier，是JDK1.5的java.util.concurrent并发包中提供的一个并发工具类。翻译为中文为“篱栅”意思，也就是栅栏。 类示意图如下： 可以看到CyclicBarrier并没有直接使用AQS来定义自己的Sync同步辅助类。但是其使用的ReentrantLock默认定义了NonfairSync。ReentrantLock是排它的，非共享，内部有公平和非公平策略实现。 ① Javadoc CyclicBarrier是一个同步辅助类，它允许一组线程相互等待直到所有线程都到达一个公共的屏障点。CyclicBarrier在涉及一定大小的线程的程序而这些线程有时必须彼此等待的情况下很有用。这个屏障之所以用循环修饰，是因为在所有的线程释放之后，这个屏障是可以重新使用的。 CyclicBarrier支持可选择的Runnable命令(实例)，在团队中的最后一个线程到达之后，但是在释放任何线程之前，每个屏障点运行一次(执行Runnable命令的run方法)。在内部任何一个线程继续之前，这种屏障操作对于更新共享状态是有用的。 下面是在并行分解设计中使用屏障的示例：...