CyclicBarrier 可实现无需重置、自动复用的确定性多轮并发测试，关键在于固定线程数、每轮仅调用一次 await()、显式控制总轮次并避免 reset() 和共享状态竞争。
利用 CyclicBarrier 的非阻塞自动复用特性构造确定性多轮次并发压力测试，关键在于**不依赖外部同步信号、不手动重置、让所有线程自然等待并同步进入下一轮**——这正是 CyclicBarrier 区别于 CountDownLatch 的核心优势。
理解“非阻塞自动复用”的真实含义
所谓“非阻塞”并非指 await() 不阻塞，而是指：一旦所有参与线程都到达屏障点，CyclicBarrier 会立即释放全部线程，并自动进入下一轮等待状态，无需调用 reset() 或重建对象。这种复用是线程安全且原子的。
注意：它不是“无锁”或“零开销”，而是“一次初始化、多轮循环复用”的语义保障。
设计确定性多轮测试的三要素
要确保每轮执行严格对齐、轮次计数准确、结果可复现，需满足：
-
固定线程池 + 固定参与数：使用
FixedThreadPool，线程数 =CyclicBarrier构造参数（如new CyclicBarrier(10)），避免线程动态增减导致等待数不匹配 -
每轮只调用一次
await()：每个线程在本轮业务逻辑结束后、下轮开始前调用一次，不可遗漏或重复；否则某轮可能提前释放或永久阻塞 -
显式控制总轮次 + 终止机制：通过共享变量（如
AtomicInteger round）控制循环次数，在所有线程完成最后一轮后统一退出，避免因 barrier 重用导致无限循环
典型实现结构（Java 示例片段）
以下为精简可运行骨架（省略异常处理与统计收集）：
int threadCount = 8;
int totalRounds = 5;
CyclicBarrier barrier = new CyclicBarrier(threadCount);
AtomicInteger currentRound = new AtomicInteger(1);
ExecutorService pool = Executors.newFixedThreadPool(threadCount);
for (int i = 0; i < threadCount; i++) {
pool.submit(() -> {
while (currentRound.get() <= totalRounds) {
// ▶ 执行本轮压测任务（如 HTTP 请求、DB 查询）
doOneWorkItem();
try {
// ▶ 同步等待本回合结束 —— 这里触发 barrier 复用
barrier.await(); // 所有 threadCount 个线程到齐后，同时向下执行
// ▶ 可选：仅由主线程/指定线程做轮次日志或检查
if (Thread.currentThread() == Thread.activeCount()) {
System.out.println("Round " + currentRound.getAndIncrement() + " completed");
}
} catch (Exception e) {
Thread.currentThread().interrupt();
return;
}
}
});
}
pool.shutdown();
pool.awaitTermination(1, TimeUnit.MINUTES);
说明：实际中建议将轮次检查放在 await() 前，并用 break 退出循环，避免最后一轮后仍尝试 await；也可用 barrier.await(timeout, unit) 防止单点故障拖垮整轮。
规避常见陷阱
这些细节决定测试是否真正“确定性”：
-
禁止在 barrier 后修改共享状态再用于下轮计算：例如在
await()后更新计数器却未加锁，会导致下轮输入不一致 -
不要混用
reset()：调用reset()会中断当前等待并清空状态，破坏轮次连续性，违背“自动复用”初衷 -
异常线程必须退出而非重试：若某线程在
doOneWorkItem()中抛异常且未终止，它不会调用await()，导致 barrier 永久阻塞（broken state）；应捕获异常后return或调用barrier.reset()并整体失败 -
避免 barrier 内部回调（
Runnable）耗时操作：构造时传入的 barrier action 应极轻量（如打点日志），否则会成为单点瓶颈，扭曲并发行为
