Java多线程同步问题：CountDownLatch使用案例

原创灰太狼 2024-12-13 06:57 12阅读 0赞

`CountDownLatch`是Java并发工具包中的一个类，主要用于协调多个线程的执行顺序。当一个或多个线程等待某个事件发生时，可以使用`CountDownLatch`来控制它们的等待。

以下是一个简单的使用`CountDownLatch`的案例：

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

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

public void task1() {
        try {
            System.out.println("Task 1 starts...");
            countDownLatch.countDown();
            System.out.println("Task 1 ends...");

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

public void task2() {
        try {
            System.out.println("Task 2 starts...");
            countDownLatch.await(5, TimeUnit.SECONDS); // 等待任务1完成
            System.out.println("Task 2 ends...");

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

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

Thread thread1 = new Thread(example::task1);
        Thread thread2 = new Thread(example::task2);

thread1.start();
        thread2.start();

// 确保主线程不会过早退出
        try {
            thread1.join(); // 等待thread1执行完毕
            thread2.join(); // 等待thread2执行完毕

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

在这个例子中，`task1`和`task2`是两个线程。`CountDownLatch`用于控制`task1`完成后再开始等待5秒的`task2`。

当主线程执行完后，会通过`thread1.join()`和`thread2.join()`来确保主线程不会过早退出，从而保证了多线程同步的效果。