Java并发编程：CountDownLatch与CyclicBarrier的区别案例

原创旧城等待， 2024-11-22 20:45 4阅读 0赞

`CountDownLatch`和`CyclicBarrier`都是Java中用于管理多个线程的同步工具。它们之间有以下几点区别：

1. **原理不同**：
- `CountDownLatch`是基于原子操作，当它的计数器减到0时，所有等待的线程会被唤醒。
- `CyclicBarrier`是基于事件触发的，每个线程到达屏障后会立即阻塞，直到有一个线程成功通过屏障并调用`barrier.await(long timeout, TimeUnit unit)``来唤醒所有阻塞的线程。

2. **使用场景不同**：
- `CountDownLatch`用于线程间逐个执行的任务，例如一个大任务拆分成多个子任务，每个子任务完成后都会调用`countDown()`方法来减少计数器。
- `CyclicBarrier`适用于需要按组行动的场景，例如多台机器同步执行某个操作，每次操作完成时会形成一个屏障，所有等待的线程到达后会被阻塞。

案例：

以下是一个简单的`CountDownLatch`和`CyclicBarrier`的区别案例：

```java
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;

public class CounterAndCyclicBarrier {
    public static void main(String[] args) {
        // 使用CountDownLatch示例
        CountDownLatch countDownLatch = new CountDownLatch(3);
        Thread thread1 = new Thread(() -> {
            try {
                countDownLatch.countDown();
                System.out.println("Thread 1: Decrement complete.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                countDownLatch.await(5, TimeUnit.SECONDS));
                System.out.println("Thread 2: Waited and decrement complete.");
            } catch (InterruptedException | TimeoutException e) {
                e.printStackTrace();
            }
        }));

// 启动线程
        thread1.start();
        thread2.start();

// 等待所有线程完成
        try {
            countDownLatch.await();
            System.out.println("Main: All threads completed.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，`CountDownLatch`用于三个线程相互协作，每个线程结束后调用`countDown()`减少计数器。而`CyclicBarrier`则用于两个线程同步执行某个操作，完成操作后所有等待的线程会被阻塞并唤醒。