Java中的并发编程：CountDownLatch使用案例

原创向右看齐 2024-11-25 03:57 138阅读 0赞

CountDownLatch是Java并发工具包（java.util.concurrent）中的一个同步器，主要用于协调多个线程的执行。

CountDownLatch的主要特性是它有一个初始的计数器值。当一个线程调用await()方法时，这个线程会阻塞直到countdown latch的计数值减到0。

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

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

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

public void thread1() {
        System.out.println("Thread 1 starting...");
        try {
            countDownLatch.await();
            System.out.println("Thread 1 completed.");
        } catch (InterruptedException e) {
            System.out.println("Thread 1 interrupted: " + e.getMessage());
        }
    }

public void thread2() {
        System.out.println("Thread 2 starting...");
        try {
            countDownLatch.countDown(); // 一旦这个方法被调用，countdown latch的计数器会立即减少到0
            countDownLatch.await();
            System.out.println("Thread 2 completed.");
        } catch (InterruptedException e) {
            System.out.println("Thread 2 interrupted: " + e.getMessage());
        }
    }

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

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

thread1.start();
        thread2.start();
    }
}
```

在这个例子中，`thread1`和`thread2`是两个线程。它们共同使用一个CountDownLatch来协调执行。

当线程`thread1`调用`await()`方法时，它会阻塞直到计数值减到0。同时，`thread2`在调用`countDown()`后，也会使`await()`的线程`thread1`立即醒来。

最后，当所有线程都完成执行后，程序会正常结束。