Java中并发工具类如CountDownLatch的使用示例

原创ゝ一世哀愁。 2024-10-23 19:51 29阅读 0赞

`CountDownLatch` 是 Java 中用于协调多个线程的一种工具。当一个线程到达 `countDown()` 方法时，它会将计数器减少1，而其他等待计数器减到0的线程就会被唤醒。

以下是一个简单的使用示例：

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

public class CountDownLatchExample {
    public static void main(String[] args) {
        // 创建一个计数器，初始值为3
        CountDownLatch countDown = new CountDownLatch(3);

// 创建两个线程，每个线程都会调用countDown的down方法来减少计数器
        Thread thread1 = new Thread(() -> {
            try {
                countDown.countDown();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                countDown.countDown();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

// 启动两个线程
        thread1.start();
        thread2.start();

// 等待计数器归零，表示所有任务都已经完成
        try {
            countDown.await(5, TimeUnit.SECONDS)); // 5秒后如果还没有到达0，则抛出超时异常
        } catch (InterruptedException | TimeoutException e) {
            e.printStackTrace();
        }
    }
}
```

在这个示例中，我们创建了一个计数器`countDown`初始值为3。然后创建了两个线程，每个线程都会调用`countDown.countDown()`来减少计数器。

最后，我们等待计数器归零（即计数器变为0），表示所有任务都已经完成。如果在5秒后还没有到达0，就会抛出超时异常。