当前位置：首页 > news >正文

`CyclicBarrier` 是 Java 中的一个同步辅助工具类，它允许一组线程相互等待，直到所有线程都达到了某个公共屏障点（barrier point）

news 2025/7/29 12:09:59

`CyclicBarrier` 是 Java 中的一个同步辅助工具类，它允许一组线程相互等待，直到所有线程都达到了某个公共屏障点（barrier point）。当所有线程都到达屏障点时，它们可以继续执行后续操作。`CyclicBarrier` 的特点是可以重复使用，即当一组线程都到达屏障点并释放后，可以再次使用同一个 `CyclicBarrier` 对象来等待下一组线程。

### 场景描述
假设我们有一个任务，需要多个线程共同完成，这些线程各自执行一部分工作，但必须在所有线程都完成自己的部分工作后，才能一起执行下一步。例如，一个团队需要完成多个独立的数据分析任务，但最终的报告需要在所有数据都分析完成后才能生成。

### 步骤

1. **初始化 CyclicBarrier**:
创建一个 `CyclicBarrier` 对象，并设置一个参数，表示需要等待的线程数量。

```java
int numberOfThreads = 5; // 假设有5个线程
CyclicBarrier barrier = new CyclicBarrier(numberOfThreads);
```

2. **创建并启动线程**:
为每个任务创建一个线程，这些线程将执行各自的任务。

```java
for (int i = 0; i < numberOfThreads; i++) {
new Thread(new TaskRunner(i, barrier)).start();
}
```

3. **定义任务**:
实现 `TaskRunner` 线程任务，用于执行特定的任务，并在完成后等待其他线程。

```java
class TaskRunner implements Runnable {
private final int taskNumber;
private final CyclicBarrier barrier;

public TaskRunner(int taskNumber, CyclicBarrier barrier) {
this.taskNumber = taskNumber;
this.barrier = barrier;
}

@Override
public void run() {
try {
System.out.println("Task " + taskNumber + " is running.");
// 执行任务
// 模拟任务执行时间
Thread.sleep((long) (Math.random() * 1000));
System.out.println("Task " + taskNumber + " is completed.");
// 等待其他线程完成
barrier.await();
// 所有线程都到达屏障点后执行的代码
System.out.println("All tasks completed, proceeding to next step for task " + taskNumber);
} catch (InterruptedException | BrokenBarrierException e) {
Thread.currentThread().interrupt();
System.out.println("Task " + taskNumber + " was interrupted or barrier was broken.");
}
}
}
```