Java并发工具类如CountDownLatch、CyclicBarrier的理解和使用示例

原创旧城等待， 2024-10-20 00:18 72阅读 0赞

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

1. CountDownLatch：
   - CountDownLatch最初用于一个或多个等待其他任务完成的线程。
   - 当创建CountDownLatch时，需要指定初始计数值。当某个线程调用await()方法时，它会将控制权交还给调用它的那个线程的调用者（即可能是一个匿名内部类或者静态方法），并等待countdown到达0。

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

public class CountDownLatchExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个CountDownLatch，初始值为3
        CountDownLatch countDownLatch = new CountDownLatch(3);

// 定义两个线程，每个线程都会调用countDownLatch的await()方法
        Thread thread1 = new Thread(() -> {
            try {
                countDownLatch.await(); // 等待countdown到达0
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Thread 1 completed"); // 主线程会打印这一行
        }));

Thread thread2 = new Thread(() -> {
            try {
                countDownLatch.await(); // 等待countdown到达0
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Thread 2 completed"); // 主线程会打印这一行
        }));

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

// 等待所有线程执行完毕，主线程才会继续执行
        countDownLatch.countDown(); // 这个操作是线程安全的

System.out.println("Main completed"); // 主线程会打印这一行
    }
}
```
在上述示例中，`CountDownLatch`被用来协调两个线程（`thread1`和`thread2`）的执行。当所有计数到达0时，所有等待的线程会被唤醒并继续执行。