Java并发工具类如CountDownLatch的应用实例

原创缺乏、安全感 2024-12-09 20:45 15阅读 0赞

在Java中，CountDownLatch是一种同步工具类，主要用于控制多个线程的执行顺序。当一个线程唤醒它的downstream（下游）时，downstream需要通过countDown方法将计数器减1。

下面是一个简单的应用实例：

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

public class CountDownLatchExample {

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

// 创建三个线程，每个线程执行countDown方法
        Thread thread1 = new Thread(() -> {
            try {
                countDownLatch.countDown();
                System.out.println("Thread 1 counted down.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                countDownLatch.countDown();
                System.out.println("Thread 2 counted down.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread3 = new Thread(() -> {
            try {
                countDownLatch.countDown();
                System.out.println("Thread 3 counted down.");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

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

// 等待所有线程执行完毕后关闭计数器
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("All threads have finished.");
    }
}
```

在这个例子中，我们创建了一个初始值为3的CountDownLatch。然后创建了三个线程，每个线程执行countDown方法减1计数器。当所有线程都完成减1操作后，主线程通过await方法等待计数器关闭，表示所有线程都已经执行完毕。