Java并发工具：CountDownLatch、CyclicBarrier的应用案例

原创水深无声 2024-11-01 14:51 11阅读 0赞

Java并发工具类是Java并发编程中非常重要的一部分，它们帮助我们处理多线程之间的协调问题。`CountDownLatch`和`CyclicBarrier`是两个常用的同步辅助类，它们在不同的场景下有着各自的应用。

### CountDownLatch`CountDownLatch`是一个同步辅助类，在完成一组正在其他线程中执行的操作之前，它允许一个或多个线程一直等待。

**应用案例：**

假设我们有一个任务，需要等待多个线程完成各自的工作后，主线程才能继续执行。比如，一个主线程需要等待三个子线程完成各自的数据加载任务。

```javapublic class CountDownLatchExample {
 public static void main(String[] args) throws InterruptedException {
int threadCount =3;
CountDownLatch latch = new CountDownLatch(threadCount);

for (int i =0; i < threadCount; i++) {
 new Thread(() -> {
 try {
//模拟数据加载 TimeUnit.SECONDS.sleep(2);
 System.out.println(Thread.currentThread().getName() + " finished loading data.");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
 latch.countDown(); //完成一个任务，计数减一 }
 }).start();
 }

latch.await(); //等待所有线程完成 System.out.println("All threads have finished loading data.");
 }
}
```### CyclicBarrier`CyclicBarrier`是一个同步辅助类，它允许一组线程相互等待，直到所有线程都到达一个公共屏障点（barrier point）。

**应用案例：**

假设我们有一个任务，需要多个线程协同工作，每个线程完成自己的部分后，需要等待其他线程也完成，然后一起进入下一个阶段。比如，一个游戏场景中，多个玩家需要在起点集合，然后一起开始游戏。

```javapublic class CyclicBarrierExample {
 public static void main(String[] args) throws InterruptedException {
int playerCount =3;
CyclicBarrier barrier = new CyclicBarrier(playerCount, () -> {
 System.out.println("All players are ready to start the game!");
 });

for (int i =0; i < playerCount; i++) {
 new Thread(() -> {
 try {
//模拟玩家准备时间 TimeUnit.SECONDS.sleep(2);
 System.out.println(Thread.currentThread().getName() + " is ready.");
 barrier.await(); //等待其他玩家} catch (Exception e) {
e.printStackTrace();
 }
 }).start();
 }
 }
}
```在这两个案例中，`CountDownLatch`适用于一次性的等待多个线程完成的场景，而`CyclicBarrier`适用于需要周期性地等待一组线程的场景。它们都是协调多线程执行的强大工具。