Java并发工具：CountDownLatch、CyclicBarrier等实战解析

原创迈不过友情╰ 2024-09-12 01:09 287阅读 0赞

在Java并发编程中，CountDownLatch和CyclicBarrier是两种常用的同步工具。下面我们将对它们进行实战解析。

1. CountDownLatch

CountDownLatch是一种倒计数类型的对象，它最初有一个表示总的等待次数的初始值。

使用场景：当一个线程需要多个其他线程执行完后才能继续时，可以用CountDownLatch来实现。

实战解析（示例）：
```java
import java.util.concurrent.CountDownLatch;

public class CounterExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个 CountDownLatch
        CountDownLatch countDownLatch = new CountDownLatch(3);

// 创建三个线程，每个线程执行一步操作
        Thread t1 = new Thread(() -> {
            try {
                countDownLatch.await(500, TimeUnit.MILLISECONDS));
                System.out.println("Thread 1 completed");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread t2 = new Thread(() -> {
            try {
                countDownLatch.await(1000, TimeUnit.MILLISECONDS));
                System.out.println("Thread 2 completed");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }));

Thread t3 = new Thread(() -> {
            try {
                countDownLatch.await(500, TimeUnit.MILLISECONDS));
                System.out.println("Thread 3 completed");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        });

// 启动线程
        t1.start();
        t2.start();
        t3.start();

// 等待所有线程执行完成，然后关闭 CountDownLatch
        countDownLatch.countDown();
    }
}
```
在这个例子中，CountDownLatch用于控制多个线程的执行顺序。当线程执行`await()`方法并传入期望等待时间时，如果到达或超过了设定的时间，则当前线程会立即继续执行；否则，线程会被阻塞，直到达到等待条件。

CyclicBarrier是Java并发API中的另一种同步工具，它用于一组等待某个事件的线程。当所有线程完成一个循环（ barrier.await()）后，屏障将打开并允许所有线程通过。