Java并发编程实战中，J.U.C的CyclicBarrier如何实现高效同步与协作？

本文共计918个文字，预计阅读时间需要4分钟。

在JDK API中，这是一个介绍同步辅助类的开头内容：它允许一组线程相互等待，直到达到某个共同的屏障点（common barrier point）。

在JDKAPI中是这么介绍的一个同步辅助类它允许一组线程互相等待直到到达某个公共屏障点(commonbarrierpoint)。在涉

在JDK API中是这么介绍的

一个同步辅助类它允许一组线程互相等待直到到达某个公共屏障点 (common barrier point)。在涉及一组固定大小的线程的程序中这些线程必须不时地互相等待此时 CyclicBarrier 很有用。因为该 barrier 在释放等待线程后可以重用所以称它为循环 的 barrier。

CyclicBarrier 支持一个可选的 Runnable 命令在一组线程中的最后一个线程到达之后(但在释放所有线程之前)该命令只在每个屏障点运行一次。若在继续所有参与线程之前更新共享状态此屏障操作 很有用。

对于失败的同步尝试CyclicBarrier 使用了一种要么全部要么全不 (all-or-none) 的破坏模式如果因为中断、失败或者超时等原因导致线程过早地离开了屏障点那么在该屏障点等待的其他所有线程也将通过 BrokenBarrierException(如果它们几乎同时被中断则用 InterruptedException)以反常的方式离开。

CyclicBarrier分析

CyclicBarrier结构如下

从上图可以看到CyclicBarrier内部使用ReentrantLock独占锁实现的。