Java并发工具：CountDownLatch和CyclicBarrier的使用示例

原创ゞ浴缸里的玫瑰 2024-10-07 11:18 60阅读 0赞

CountDownLatch和CyclicBarrier都是Java中常用的并发工具，主要用于协调多个线程的执行。

1. CountDownLatch：

CountDownLatch最初用于一个或多个任务完成之后通知其他等待的任务。它有一个初始值，当一个任务通过调用countDown()方法来消耗这个计数器时，这个值就会减少。

使用示例：
```java
import java.util.concurrent.CountDownLatch;

public class CountDownLatchExample {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch = new CountDownLatch(3);

// 创建并启动三个线程，每个线程都会调用countDown()方法来消耗计数器。
        Thread thread1 = new Thread(() -> countDownLatch.countDown()));
        Thread thread2 = new Thread(() -> countDownLatch.countDown()));
        Thread thread3 = new Thread(() -> countDownLatch.countDown()));

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

// 等待所有线程完成任务，然后调用countUp()方法来将计数器恢复到初始值。
        countDownLatch.await();

System.out.println("All tasks completed!");
    }
}
```

2. CyclicBarrier：

CyclicBarrier是一种同步工具，用于当一个屏障（barrier）被满足时，阻止所有等待该屏障的线程继续执行。一旦一个线程通过屏障，它会立即返回给调用它的线程。

使用示例：
```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建CyclicBarrier，初始值为2。
        CyclicBarrier cyclicBarrier = new CyclicBarrier(2);

// 创建并启动两个线程，每个线程都会调用cyclicBarrier.await()方法来等待屏障被满足。
        Thread thread1 = new Thread(() -> {
            try {
                cyclicBarrier.await();
                System.out.println("Task 1 completed by barrier!");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                cyclicBarrier.await();
                System.out.println("Task 2 completed by barrier!");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

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

// 等待屏障被满足，即两个任务都完成。
        cyclicBarrier.await();

System.out.println("All tasks completed by barrier!");
    }
}
```

这两个工具在Java并发编程中有着广泛的应用。