Java并发工具库：CyclicBarrier和CountDownLatch示例

原创小鱼儿 2024-10-16 09:36 72阅读 0赞

在Java中，`CyclicBarrier`和`CountDownLatch`是两种常用的并发工具。下面我会分别给出这两个类的使用示例。

1. CyclicBarrier

`CyclicBarrier`允许一组线程等待其他线程达到特定屏障点后一起继续执行。

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

public class CyclicBarrierExample {
    public static void main(String[] args) throws Exception {
        // 创建一个CyclicBarrier，需要的线程数为2
        CyclicBarrier barrier = new CyclicBarrier(2);

// 创建两个线程，分别尝试达到屏障点
        Thread thread1 = new Thread(() -> {
            try {
                barrier.await();  // 等待屏障点到达
                System.out.println("Thread1 reached barrier point");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }));

Thread thread2 = new Thread(() -> {
            try {
                barrier.await();  // 等待屏障点到达
                System.out.println("Thread2 reached barrier point");
            } catch (Exception e) {
                e.printStackTrace();
            }
        }));

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

// 线程执行完毕后，关闭CyclicBarrier
        barrier.await();  // 这一步是必须的，确保屏障点都被达到

System.out.println("All threads have reached barrier point");
    }
}
```
这段代码首先创建了一个`CyclicBarrier`，需要的线程数为2。然后创建了两个线程，每个线程都在尝试达到屏障点。

当所有线程都成功达到屏障点时，`CyclicBarrier`会被关闭。最后输出一条信息表示所有线程都已经到达屏障点。