多线程同步控制的复杂性：CountDownLatch使用示例

原创分手后的思念是犯贱 2024-11-01 15:45 41阅读 0赞

多线程同步控制是并发编程中的一个重要概念，它涉及到如何协调多个线程的执行顺序，以确保程序的正确性和性能。`CountDownLatch` 是 Java 中的一个同步辅助类，它允许一个或多个线程等待一组操作在其他线程中完成。

`CountDownLatch` 的基本工作原理是，通过一个计数器来控制线程的等待和释放。当计数器的值减到0时，所有等待的线程都会被释放。

下面是一个简单的 `CountDownLatch` 使用示例：

```javaimport java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
 public static void main(String[] args) {
//假设我们有5个任务需要完成 final int taskCount =5;
CountDownLatch latch = new CountDownLatch(taskCount);

// 创建并启动5个线程来执行任务 for (int i =0; i < taskCount; i++) {
 new Thread(new Worker(latch)).start();
 }

//等待所有任务完成 try {
 latch.await();
 System.out.println("所有任务完成！");
} catch (InterruptedException e) {
e.printStackTrace();
 }
 }

static class Worker implements Runnable {
 private final CountDownLatch latch;

public Worker(CountDownLatch latch) {
 this.latch = latch;
 }

@Override public void run() {
 try {
//模拟任务执行时间Thread.sleep((long) (Math.random() *1000));
 System.out.println(Thread.currentThread().getName() + "完成任务");
} finally {
//任务完成后，计数器减1 latch.countDown();
 }
 }
 }
}
```在这个示例中：

1.我们创建了一个 `CountDownLatch` 对象，其计数器初始化为5，表示有5个任务需要完成。
2.我们创建了5个线程，每个线程执行 `Worker`任务。每个 `Worker` 在执行完毕后会调用 `countDown()` 方法，将计数器减1。
3. 在主线程中，我们调用 `latch.await()` 方法，这会导致主线程等待直到 `CountDownLatch` 的计数器减到0。只有当所有5个任务都完成（即计数器减到0）后，主线程才会继续执行，打印出 "所有任务完成！"。

这个示例展示了如何使用 `CountDownLatch`来确保主线程等待所有子线程任务完成后再继续执行。这是多线程同步控制中一个非常实用的工具。