Java并发编程：CountDownLatch与CyclicBarrier实例

原创ゝ一世哀愁。 2024-10-08 11:48 73阅读 0赞

在Java的并发编程中，CountDownLatch和CyclicBarrier是两种常用的同步工具。下面我们将通过实例来详细理解它们。

1. CountDownLatch:

CountDownLatch是一种线程间依赖关系的工具。它初始状态为`n`（n>0），当一个或多个等待它的线程执行完一个操作后调用`countDown()`方法时，将`n-1`设置到CountDownLatch中。若想唤醒所有等待的线程，可以调用`await()`方法。

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

public class CountDownLatchExample {
    private final CountDownLatch countDownLatch = new CountDownLatch(2);

public void startThreads() {
        new Thread(() -> { // 线程1的任务
            countDownLatch.countDown(); // 调用countDown方法
            System.out.println("线程1任务完成。"); // 输出信息
        }}).start();

new Thread(() -> { // 线程2的任务
            try {
                countDownLatch.await(); // 调用await方法
                System.out.println("线程2任务完成。"); // 输出信息
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }}).start();
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample();
        example.startThreads();
    }
}
```
在这个例子中，线程1和线程2分别执行任务。当它们完成任务后调用`countDown()`方法，使CountDownLatch的值减一。然后在等待这个事件发生（调用`await()`）时，可以做其他事情。

2. CyclicBarrier：

CyclicBarrier是Java并发API中的一个同步工具，它允许多个线程同时到达屏障，当所有线程都通过屏障后，屏障会自动关闭并阻断后续线程的进入。

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

public class CyclicBarrierExample {
    private final CyclicBarrier cyclicBarrier = new CyclicBarrier(2);

public void startThreads() {
        new Thread(() -> { // 线程1的任务
            try {
                cyclicBarrier.await(); // 调用await方法
                System.out.println("线程1任务完成。"); // 输出信息
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("开始进入屏障。"); // 输出提示信息
        }}).start();

new Thread(() -> { // 线程2的任务
            try {
                cyclicBarrier.await(); // 调用await方法
                System.out.println("线程2任务完成。"); // 输出信息
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("开始进入屏障。"); // 输出提示信息
        }}).start();
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample();
        example.startThreads();
    }
}
```
在这个例子中，两个线程`thread1`和`thread2`同时开始执行任务。当它们都调用`cyclicBarrier.await()`方法等待屏障时，CyclicBarrier会允许所有线程通过屏障。当所有线程都完成屏障后，屏障将关闭并阻断后续线程的进入。

总结：CountDownLatch和CyclicBarrier是Java并发编程中两种常用的同步工具，它们各自有明确的应用场景和功能特点。