Java并发编程：理解并使用CountDownLatch的例子

原创灰太狼 2024-11-15 11:51 34阅读 0赞

CountDownLatch是Java并发工具箱`java.util.concurrent`中的一个接口。它主要用于协调多个线程的执行，使得某个或某些线程在其他线程完成特定操作后才会继续执行。

以下是一个使用CountDownLatch的例子：

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

public class CounterExample {
    private CountDownLatch latch = new CountDownLatch(1);

// 线程A，需要等待B完成后才能继续
    public void threadA() throws InterruptedException {
        System.out.println("Thread A starting...");
        
        // 启动线程B，当其执行完成时，会调用latch.countDown()
        new Thread(() -> {
            System.out.println("Thread B starting...");
            
            try {
                // 确保B线程在执行过程中不会立即结束
                Thread.sleep(2000); // 假设这是一个耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                System.out.println("Thread B ending...");
                
                // 当线程B执行完成并调用countDown方法后，latch的计数器会减少1
                latch.countDown();
            }
        })).start();

// 在A线程中等待B线程完成后继续执行
        try {
            latch.await(); // wait until count reaches zero
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

System.out.println("Thread A ending...");
    }

public static void main(String[] args) throws InterruptedException {
        CounterExample example = new CounterExample();
        
        // 启动线程A，等待B完成后继续执行
        Thread threadA = new Thread(example::threadA));
        threadA.start();

// 等待线程A完成执行
        threadA.join();
    }
}
```

在这个例子中，线程`Thread A`需要等待另一个线程`Thread B`完成某个耗时操作后才能继续。`CountDownLatch`通过`countDown()`方法来控制这个同步过程。