Java并发工具库：CountDownLatch的使用示例

原创灰太狼 2024-12-13 08:51 13阅读 0赞

`CountDownLatch`是Java并发工具库中的一个类，主要用于协调多个线程的执行。

使用示例：

1. 创建CountDownLatch实例

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

public class CountDownLatchExample {
    private CountDownLatch countDownLatch;
    
    public CountDownLatchExample(int initialCount) {
        countDownLatch = new CountDownLatch(initialCount);
    }
    
    // 线程执行方法，需要等待countDown的计数降为0
    public void threadAction() throws InterruptedException {
        countDownLatch.await();  // 等待countDown的计数降为0
        System.out.println("Thread action completed");
    }
}
```

2. 在多线程中使用CountDownLatch

创建多个线程，每个线程调用`threadAction()`方法。在`threadAction()`方法中，我们通过构造函数传入初始值，然后调用`await()`来等待计数降为0。

例如：

```java
public class Main {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatchExample example = new CountDownLatchExample(3);  // 创建一个CountDownLatch，初始值为3

Thread thread1 = new Thread(example::threadAction));  // 创建第一个线程
        Thread thread2 = new Thread(example::threadAction));  // 创建第二个线程
        Thread thread3 = new Thread(example::threadAction));  // 创建第三个线程

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

thread1.join();  // 等待线程1执行完毕
        thread2.join();  // 等待线程2执行完毕
        thread3.join();  // 等待线程3执行完毕

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

以上就是CountDownLatch的使用示例。在实际应用中，可以根据需要调整计数器的初始值和多个线程的执行方式。