Java中的并发问题：CountDownLatch和CyclicBarrier实例解析

原创古城微笑少年丶 2024-10-24 10:51 8阅读 0赞

在Java中，CountDownLatch和CyclicBarrier是两种常用的并发协调工具。它们主要用于控制多个线程的执行顺序。

1. CountDownLatch

CountDownLatch是一种倒计时信号量。当一个线程调用countDown()方法将计数器减1，而其他的线程等待该计数器值为0时才会被唤醒。

实例解析：
```java
import java.util.concurrent.CountDownLatch;

public class CounterExample {
    private CountDownLatch countDownLatch;

public CounterExample(int initialCount) {
        this.countDownLatch = new CountDownLatch(initialCount);
    }

// 线程A，当countDown次数大于0时执行
    public void threadA() throws InterruptedException {
        for (int i = 0; i < 5; i++) { // 重复5次操作
            countDownLatch.countDown(); // 减1计数器
        }

countDownLatch.await(); // 等待计数器为0
    }

public static void main(String[] args) {
        CounterExample counter = new CounterExample(3);
        
        Thread threadA = new Thread(counter::threadA);
        Thread threadB = new Thread(counter::threadA);

threadA.start();
        threadB.start();

// 等待所有线程执行完毕
        threadA.join();
        threadB.join();
    }
}
```
在上述例子中，我们创建了一个CountDownLatch，初始计数为3（表示有3个任务等待）。线程A执行了5次countDown操作，每完成一次就减1。

当线程A完成所有countDown操作后，它调用了await方法来等待计数器变为0。同时，另一个线程B也被创建并开始执行。

当所有线程都执行完毕后，main方法中的join方法会将所有线程挂起，直到它们执行完毕才会继续执行后续代码。