Java中的并发工具类：CountDownLatch与CyclicBarrier示例

原创红太狼 2024-12-09 14:54 11阅读 0赞

在Java中，CountDownLatch和CyclicBarrier是两种常用的并发工具类。它们主要用于协调多个线程的执行。

1. CountDownLatch（倒计时）

- 原理：当一个线程等待其他线程完成某个操作后释放锁，就可以通过CountDownLatch实现倒计时的效果。

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

public class CountDownLatchExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个CountDownLatch实例
        CountDownLatch latch = new CountDownLatch(2);

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

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

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

// 等待倒计时结束
        latch.await();

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

2. CyclicBarrier（循环栅栏）

- 原理：CyclicBarrier是Java并发包中的一个工具类，当线程数量达到预设值后，所有等待的线程都会被唤醒并进入屏障内部。

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

public class CyclicBarrierExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个CyclicBarrier实例，线程数量为2
        CyclicBarrier barrier = new CyclicBarrier(2);

Thread thread1 = new Thread(() -> {
            try {
                barrier.await();
                System.out.println("Thread 1 entered the barrier.");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                barrier.await();
                System.out.println("Thread 2 entered the barrier.");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }));

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

// 等待所有线程都到达屏障内部
        barrier.await();

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

以上就是CountDownLatch和CyclicBarrier在Java中的简单使用示例。