Ru果你在并发编程的路上走了一段，肯定听说过 sync.WaitGroupsync/atomicCountDownLatch 等工具。但当业务需要让一组 goroutine 多次“齐头并进”，又不想每次重新建一个同步对象时CyclicBarrier 就会悄然登场。

CyclicBarrier 顾名思义是一种Ke以循环使用的屏障。想象一条围栏，所有参与者必须站到这条围栏前才Neng一起通过；当Zui后一个人到位后围栏被抬起，大家齐步前进。随后这条围栏会自动恢复原样，等待下一轮的集合。

与一次性“倒计数”器不同，CyclicBarrier 在每次放行后会自动复位，因而Ke以在同一个实例里完成多轮同步。

它的内部计数器在每轮结束后会被重置为初始值。

开发者无需再创建新对象，只要调用一次 await/Await 即可进入下一轮。

标准库并没有直接提供 CyclicBarrier，但社区Yi经有几款成熟实现，其中Zui受欢迎的是 。它的 API 与 Java 版相似，却兼容 Go 的上下文机制：

func New CyclicBarrier
func NewWithAction error) CyclicBarrier
// 方法
Await error   // 等待全部到齐或被取消
Reset                           // 强制复位
GetNumberWaiting int            // 当前Yi阻塞的 goroutine 数
GetParties int                  // 总参与者数
IsBroken bool                   // 是否处于异常状态

其中 action 参数Ke以让你在每轮 “Zui后一个” 到达时执行一次自定义逻辑——比如统计、日志或资源清理。

下面我们用 Go 实现经典的「两个氢 + 一个氧」生成 H₂O 的模型。这里借助 CyclicBarrier + semaphore.Weighted 来控制资源配额与同步点。

package main
import (
    "context"
    "log"
    "math/rand"
    "sort"
    "sync"
    "time"
    "github.com/marusama/cyclicbarrier"
    "golang.org/x/sync/semaphore"
)
// H2O 包含两把信号量和一个循环栅栏
type H2O struct {
    semH *semaphore.Weighted // 氢原子槽位：需要两个
    semO *semaphore.Weighted // 氧原子槽位：需要一个
    bar  cyclicbarrier.CyclicBarrier
}
// 构造函数：初始化信号量和屏障
func NewH2O *H2O {
    return &H2O{
        semH: semaphore.NewWeighted,
        semO: semaphore.NewWeighted,
        bar:  cyclicbarrier.New, // 两氢 + 一氧 = 三人同行
    }
}
// 氢原子线程入口
func  hydrogen) {
    // 抢占氢槽位
    _ = h.semH.Acquire, 1)
    release                     // 打印 H 或者写入通道
    _ = h.bar.Await) // 等待其他伙伴到齐
    h.semH.Release             // 用完后归还槽位，为下一轮Zuo准备
}
// 氧原子线程入口
func  oxygen) {
    _ = h.semO.Acquire, 1)
    release
    _ = h.bar.Await)
    h.semO.Release
}
func main {
    const totalMolecules = 100   // 想生成多少个水分子
    ch := make
    releaseH := func { ch <- "H" }
    releaseO := func { ch <- "O" }
    h := NewH2O
    var wg sync.WaitGroup
    // 启动氢原子 goroutine
    for i := 0; i