Java并发工具库：CountDownLatch的应用实例

原创客官°小女子只卖身不卖艺 2024-10-12 08:57 75阅读 0赞

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

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

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

public class CountDownLatchExample {
    private CountDownLatch signal = new CountDownLatch(1);

public void workerThread() throws InterruptedException {
        System.out.println("Worker thread starting...");

// 这里模拟一个需要其他线程完成的操作
        // 例如，获取数据库中的数据
        sleepForSeconds(5);  // 假设这个操作需要5秒

System.out.println("Worker thread completed the task.");

// 当任务完成后，通知主线程
        signal.countDown();
    }

public void mainThread() throws InterruptedException {
        System.out.println("Main thread starting...");

// 创建一个worker线程
        Thread workerThread = new Thread(new WorkerThread()));
        workerThread.start();

// 主线程等待worker线程完成任务
        signal.await();

System.out.println("Main thread completed the task.");
    }

// 假设我们需要模拟一个需要时间的业务操作
    private void sleepForSeconds(int seconds) {
        try {
            Thread.sleep(seconds * 1000));  // 转换为毫秒
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，`workerThread`线程模拟一个需要5秒的操作。在主线程的`mainThread`中，通过创建并启动`workerThread`来实现这个功能。最后，主线程等待worker线程完成任务后再继续执行。