理解Java并发工具库：CountDownLatch和CyclicBarrier的应用示例

原创迷南。 2024-12-04 06:24 18阅读 0赞

Java的并发工具库提供了许多高效的同步机制，如CountDownLatch和CyclicBarrier。这里我将为你提供这两个工具的应用示例。

1. CountDownLatch

CountDownLatch是一个多线程同步工具，它有一个初始值（默认为0），当一个或多个线程调用countDown方法时，会减少这个初始值。

应用示例：
```java
import java.util.concurrent.CountDownLatch;

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

public void workerThread() throws InterruptedException {
        System.out.println("Worker thread starting...");
        // 模拟工作时间，这里设定为5秒
        Thread.sleep(5000);
        // 任务完成后，调用countDown方法
        countDownLatch.countDown();
        System.out.println("Worker thread finished.");
    }

public static void main(String[] args) throws InterruptedException {
        CountDownLatchExample example = new CountDownLatchExample();

// 创建一个新的线程，执行workerThread方法
        Thread workerThread = new Thread(example::workerThread);
        workerThread.start();

// 主线程等待计数器变为0，表示所有子任务都已完成
        example.countDownLatch.await();
    }
}
```
在这个示例中，`CountDownLatchExample`类有一个`workerThread`方法，在这个方法中模拟了一个需要5秒的工作，并在完成后调用`countDown`方法减少计数器。

在`main`方法中创建了`workerThread`线程并启动它。主线程通过调用`await()`方法来等待所有子任务完成，这是通过`CountDownLatch`的初始值来控制的。