深入理解Java并发工具：CountDownLatch、CyclicBarrier等示例

原创拼搏现实的明天。 2024-09-10 04:57 83阅读 0赞

在Java中，CountDownLatch和CyclicBarrier是两个常用的并发工具，用于协调多个线程的执行。

1. CountDownLatch

CountDownLatch是一个倒计数对象，它最初有一个初始值，当一个线程等待CountDownLatch的某个特定数量的计数器被释放时，就会调用该线程的`await()`方法。

示例：
```java
import java.util.concurrent.CountDownLatch;

public class CounterExample {
    public static void main(String[] args) {
        CountDownLatch latch = new CountDownLatch(3);

// 创建三个任务
        Thread t1 = new Thread(() -> {
            System.out.println("Task 1 started");
            try {
                latch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task 1 completed");
        }));

Thread t2 = new Thread(() -> {
            System.out.println("Task 2 started");
            try {
                latch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task 2 completed");
        }));

Thread t3 = new Thread(() -> {
            System.out.println("Task 3 started");
            try {
                latch.await();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task 3 completed");
        });

// 启动线程
        t1.start();
        t2.start();
        t3.start();

// 等待所有计数器释放后结束主线程
        try {
            latch.countDown(); // 当剩余计数为0时，调用countDown()方法
            Thread.sleep(500); // 确保主线程等待足够的时间
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```
在这个示例中，CountDownLatch的初始值是3。当三个任务（t1、t2、t3）执行完毕后，调用`countDown()`方法，将剩余计数减少到0。主线程等待所有计数器释放后结束。