深入理解Java中的并发工具：CountDownLatch案例

原创川长思鸟来 2024-10-10 07:24 58阅读 0赞

Java中的并发工具是用于管理多线程间同步和协调的。`CountDownLatch`就是一个典型的这样的工具，主要用于一个或多个线程等待其他线程的操作完成。

下面以一个简单的例子来理解`CountDownLatch`：

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

public class CountDownLatchExample {
    // 两个需要交互的线程
    private static final int NUM_THREADS = 2;
    
    // 操作完成后计数器归零，其他线程等待
    private static final int COUNTDOWN_LATCH_VALUE = 10;

public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(NUM_THREADS);

// 创建两个线程，分别对CountDownLatch进行操作
        for (int i = 0; i < NUM_THREADS; i++) {
            Thread thread = new Thread(() -> {
                // 模拟耗时操作
                try {
                    Thread.sleep(100); // 以模拟操作耗时
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

// 当操作完成后，通过CountDownLatch通知其他线程
                countDownLatch.countDown();

}), "Thread-" + i);
            thread.start();
        }

// 等待所有计数器归零，表示所有线程都已经完成他们的任务
        countDownLatch.await();
        
        System.out.println("All threads completed successfully!");
    }
}
```

在这个例子中，我们创建了两个线程，每个线程都在等待其他线程的操作完成。当操作完成后，`CountDownLatch.countDown();`会减少计数器的值，通知其他的线程。

主线程则会在所有计数器归零后才会结束，表示所有的线程都已经完成了他们的任务。