Java并发工具库：CountDownLatch与CyclicBarrier的使用实例如何

原创女爷i 2024-10-24 09:24 21阅读 0赞

在Java中，CountDownLatch和CyclicBarrier都是用于管理和协调多个线程的工具。以下是如何使用这两种工具的实际例子：

1. **CountDownLatch** - 当一个任务完成后，它会调用`countDown()`方法来减少它的计数器。其他等待这个任务完成的线程，会在计数器为0时被唤醒。

例子：
```java
// 创建一个 CountDownLatch
CountDownLatch countDownLatch = new CountDownLatch(3);

// 线程1 - 当完成后调用 countDown()
new Thread(() -> {
    System.out.println("Thread 1 starting...");
    // 这里可以模拟任务完成
    try {
        Thread.sleep(2000); // 模拟耗时操作
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    countDownLatch.countDown(); // 当前任务完成，调用 countDown()
    System.out.println("Thread 1 completed.");
}).start();

// 线程2 - 直接等待 CountDownLatch 的计数器为0
new Thread(() -> {
    System.out.println("Thread 2 starting...");
    try {
        countDownLatch.await(5000); // 设置超时时间，等待计数器为0
        if (countDownLatch.getCount() > 0) { // 如果还有未消耗的计数器，说明任务还未完成
            System.out.println("Warning: Thread 2 still waiting for completion of Thread 1.");
        } else {
            System.out.println("Thread 2 completed successfully.");
        }
    } catch (InterruptedException | TimeoutException e) {
        e.printStackTrace();
    }
    System.out.println("Thread 2 completed.");
}).start();

// 线程3 - 直接等待 CountDownLatch 的计数器为0
new Thread(() -> {
    System.out.println("Thread 3 starting...");
    try {
        countDownLatch.await(5000); // 设置超时时间，等待计数器为0
        if (countDownLatch.getCount() > 0) { // 如果还有未消耗的计数器，说明任务还未完成
            System.out.println("Warning: Thread 3 still waiting for completion of Thread 1.");
        } else {
            System.out.println("Thread 3 completed successfully.");
        }
    } catch (InterruptedException | TimeoutException e) {
        e.printStackTrace();
    }
    System.out.println("Thread 3 completed.");
}).start();
```

以上例子展示了CountDownLatch如何协调多个线程等待某个事件发生。CyclicBarrier在CountDownLatch的基础上，允许多个线程同时到达屏障点并进行下一步操作。