Java并发工具：CountDownLatch、CyclicBarrier问题演示

原创深藏阁楼爱情的钟 2024-12-10 18:12 15阅读 0赞

在Java编程中，CountDownLatch和CyclicBarrier是两种常用的并发工具，它们分别用于处理不同类型的同步场景。

1. CountDownLatch：

CountDownLatch最初是一个信号灯，它有n个计数器（初始值为n），当调用`countDown(int count)`方法时，会减少对应计数器的值。当所有计数器值归0时，CountDownLatch对象会抛出一个`SignalException`。

问题演示：
```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchDemo {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个计数器为1的CountDownLatch实例
        CountDownLatch countDownLatch = new CountDownLatch(1);

// 创建一个线程，当它运行时，会调用countDown方法来减少计数器的值
        Thread thread = new Thread(() -> {
            try {
                countDownLatch.countDown();  // 减少计数器的值
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 启动线程
        thread.start();

// 等待所有计数器归零，线程才会结束
        countDownLatch.await();  // 等待

System.out.println("Thread completed.");
    }
}
```
2. CyclicBarrier：

CyclicBarrier是一个门控队列，当一个屏障被所有等待它的线程调用后会打开。然后，每个线程都可以通过这个屏障并继续执行其任务。

问题演示：
```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierDemo {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个CyclicBarrier实例，计数为2（至少需要两个线程才能打开屏障）
        CyclicBarrier cyclicBarrier = new CyclicBarrier(2);

// 创建两个线程，当它们运行时，会调用cyclicBarrier的wait方法来等待屏障打开
        Thread thread1 = new Thread(() -> {
            try {
                // 等待屏障打开
                cyclicBarrier.await();  // wait
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                // 等待屏障打开
                cyclicBarrier.await();  // wait
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

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

System.out.println("Both threads have completed the barrier and will continue.");
    }
}
```
以上就是CountDownLatch和CyclicBarrier这两种Java并发工具的基本使用以及问题演示。