Java多线程同步问题：CountDownLatch的简单应用实例

原创落日映苍穹つ 2024-12-10 18:27 14阅读 0赞

CountDownLatch是Java并发工具类之一，它主要用于协调多个线程的工作。当一个线程调用`countDown()`方法时，该线程会释放一个计数器，计数器的初始值由构造函数确定。

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

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

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

public void task1() throws InterruptedException {
        System.out.println("Task 1 started.");
        countDownLatch.countDown(); // release a counter
        System.out.println("Task 1 completed.");
    }

public void task2() throws InterruptedException {
        System.out.println("Task 2 started.");
        // task2需要等待任务1完成再执行
        countDownLatch.await(5, TimeUnit.SECONDS)); // wait for counter to reach zero
        System.out.println("Task 2 completed.");
    }

public static void main(String[] args) throws InterruptedException {
        CountDownLatchExample example = new CountDownLatchExample();
        Thread t1 = new Thread(example::task1);
        Thread t2 = new Thread(example::task2);

t1.start(); // start task 1
        t2.start(); // start task 2

// wait for both tasks to complete
        t1.join();
        t2.join();

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

在这个例子中，我们创建了两个任务（task1和task2）以及一个CountDownLatch。当线程调用`countDown()`方法时，计数器会减一，直到计数器归零。

在主函数中，我们首先启动两个任务，然后等待它们全部完成。这个例子展示了如何使用CountDownLatch来协调多个线程的工作。