Java并发工具库：CountDownLatch、Semaphore和CyclicBarrier使用示例

原创傷城~ 2024-09-10 16:45 98阅读 0赞

Java的并发工具库包括`CountDownLatch`，`Semaphore`和`CyclicBarrier`。这些类帮助我们管理多线程环境中的资源共享和同步。

以下是这几种工具的使用示例：

1. **CountDownLatch**：用于等待一组由其他线程执行的任务完成。

```java
// 创建一个计数器，初始值为N
CountDownLatch latch = new CountDownLatch(N);

// 在每个任务中调用countDown方法减少计数器的值
for (int i = 0; i < N; i++) {
    new Thread(() -> {
        latch.countDown();
        // 这里是每个任务需要完成的操作
        // ...
    }).start();
}

// 当所有任务完成，调用await方法等待计数器为0
latch.await(); // 等待的时间由CountDownLatch的初始值决定

```

2. **Semaphore**：用于控制同时访问特定资源的数量。

```java
Semaphore semaphore = new Semaphore(1); // 初始化允许的并发线程数为1

// 访问资源（这里是一个假设的方法）前需要调用semaphore.acquire()方法获取许可
new Thread(() -> {
    try {
        semaphore.acquire(); // 获取许可后才能访问资源
        // 这里是每个任务需要完成的操作
        // ...
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

// 当所有线程访问完资源，需要调用semaphore.release()方法释放许可证
// 如果没有释放许可证，其他尝试获取许可证的线程将被阻塞
```

3. **CyclicBarrier**：用于一组等待某个事件发生后一起行动的线程。

```java
// 创建一个CyclicBarrier，初始值为N
CyclicBarrier barrier = new CyclicBarrier(N); // N表示允许的最大等待周期数

// 在每个任务中需要调用barrier.await()方法来加入循环等待
new Thread(() -> {
    try {
        barrier.await(); // 等待周期结束时加入循环
        // 这里是每个任务需要完成的操作
        // ...
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
}).start();

// 当所有任务完成了当前的循环等待周期，barrier.reset()方法将CyclicBarrier重置，允许下一个等待周期开始。
// 如果没有调用reset方法，那么当前循环等待周期结束后会进入一个无限循环等待状态
```

以上就是CountDownLatch，Semaphore和CyclicBarrier这几种Java并发工具的基本使用示例。