Java并发工具库：CountDownLatch，CyclicBarrier等实例示例

原创港控/mmm° 2024-11-21 10:33 13阅读 0赞

Java中的并发工具库主要包括`CountDownLatch`、`CyclicBarrier`和`Semaphore`等。以下是这两个主要工具类的实例示例：

1. CountDownLatch

`CountDownLatch`用于一个线程等待其他线程执行完一组特定的操作后释放信号。

```java
import java.util.concurrent.CountDownLatch;

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

// 新建两个线程，分别执行countDown和countUp操作
        Thread thread1 = new Thread(() -> countDownLatch.countDown()));
        Thread thread2 = new Thread(() -> countDownLatch.await()));

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

// 等待thread2线程完成任务
        thread2.join();

// 检查countDownLatch的计数，应该为0
        System.out.println("CountDownLatch counter: " + countDownLatch.getCount()); // 输出：CountDownLatch counter: 0
    }
}
```

2. CyclicBarrier

`CyclicBarrier`用于一组线程在某个公共点会合。

```java
import java.util.concurrent.CyclicBarrier;

public class CyclicBarrierExample {
    public static void main(String[] args) throws InterruptedException {
        // 创建一个屏障，初始值为0，表示所有线程还未到达屏障
        CyclicBarrier cyclicBarrier = new CyclicBarrier(2, "All threads met at barrier"));

// 新建两个线程，分别执行barrierWait和barrierCountDown操作
        Thread thread1 = new Thread(() -> cyclicBarrier.barrierWait()));
        Thread thread2 = new Thread(() -> cyclicBarrier.barrierCountDown()));

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

// 等待thread2线程完成任务
        thread2.join();

// 输出屏障最后到达的线程信息
        System.out.println("Last thread to reach barrier: " + cyclicBarrier.getWaiters().toArray()[0])); // 输出：Last thread to reach barrier: allthreads

// 检查屏障是否已经关闭，应该为true
        System.out.println("Is barrier closed? : " + cyclicBarrier.isBroken())); // 输出：Is barrier closed? : false
    }
}
```

以上是`CountDownLatch`和`CyclicBarrier`两个工具类的简单示例。在实际项目中，你需要根据具体需求进行设计和使用。