理解并解决：Java并发工具CountDownLatch应用实例

原创妖狐艹你老母 2024-11-23 05:21 22阅读 0赞

`CountDownLatch`是Java并发库中的一个工具类，它用于协调一组线程的活动。当一个线程等待其他线程执行完特定操作时，可以使用`CountDownLatch`。

以下是一个简单的`CountDownLatch`应用实例：

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

public class CountdownExample {
    private CountDownLatch countDownLatch = new CountDownLatch(3); // 初始化为需要等待的事件数

public void workerThread(int index) {
        try {
            System.out.println("Worker thread " + index + " started...");

// 模拟耗时操作，每个线程模拟一次
            Thread.sleep(1000 * index)); // 线程执行时间

countDownLatch.countDown(); // 当前线程完成任务后调用该方法，将事件数减1

System.out.println("Worker thread " + index + " finished.");

} catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        CountdownExample example = new CountdownExample();

// 创建3个线程
        for (int i = 0; i < 3; i++) {
            Thread workerThread = new Thread(example::workerThread, "Worker thread " + i));
            workerThread.start();
        }

try {
            countDownLatch.await(); // 主线程等待所有线程执行完
            System.out.println("All threads finished. Count down latch reached zero.");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，`CountDownLatch`用于协调三个 worker thread。每个 worker thread在完成耗时操作后会调用 `countDown()` 方法将事件数减1。主线程则会等待所有线程执行完后再继续执行后续代码。