Java并发编程中的CountDownLatch使用示例

原创港控/mmm° 2024-11-25 12:12 28阅读 0赞

CountDownLatch是Java并发工具包java.util.concurrent的一个类，它用于控制一个或多个线程等待其他线程完成工作。

以下是一个CountDownLatch的基本使用示例：

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

public class CountDownLatchExample {
    public static void main(String[] args) {
        // 创建一个计数器，初始值为3
        CountDownLatch countDown = new CountDownLatch(3);

// 创建两个线程，分别执行任务并释放资源
        Thread thread1 = new Thread(() -> {
            try {
                countDown.countDown();
                System.out.println("Thread 1 finished after waiting for " + countDown.getCount() + " count down");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                countDown.countDown();
                System.out.println("Thread 2 finished after waiting for " + countDown.getCount() + " count down");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

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

// 等待所有计数器都归零，即所有的任务完成
        try {
            countDown.await();
            System.out.println("All tasks finished");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个示例中，我们创建了一个初始值为3的CountDownLatch。然后创建了两个线程，每个线程都会调用countDown的down方法来等待计数器归零。

当所有任务完成后，CountDownLatch会自动将计数器归零，从而唤醒等待的线程。