Java并发工具类如CountDownLatch、CyclicBarrier的应用实例

原创桃扇骨 2024-11-21 13:03 112阅读 0赞

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

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

public class CountdownExample {
    private CountDownLatch countDownLatch;

public CountdownExample(int count) {
        countDownLatch = new CountDownLatch(count);
    }

public void workerThread() throws InterruptedException {
        System.out.println("Worker thread started");
        countDownLatch.countDown(); // 当计数器减少到0时，线程将被唤醒
        System.out.println("Worker thread finished");
    }

public static void main(String[] args) {
        CountdownExample example = new CountdownExample(3);

Thread workerThread1 = new Thread(example::workerThread);
        Thread workerThread2 = new Thread(example::workerThread);
        Thread workerThread3 = new Thread(example::workerThread);

// 启动所有工作线程
        workerThread1.start();
        workerThread2.start();
        workerThread3.start();

// 等待所有计数器都为0，即所有工作线程执行完毕
        countDownLatch.await();
        System.out.println("All threads finished");
    }
}
```
在这个例子中，`CountDownLatch`用于协调多个工作线程的执行。当主线程调用`await()`时，它会一直等待直到所有计数器都归零。

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

public class CyclicBarrierExample {
    private CyclicBarrier barrier;

public CyclicBarrierExample(int participants) {
        barrier = new CyclicBarrier(participants);
    }

public void workerThread() throws InterruptedException {
        System.out.println("Worker thread started");
        barrier.await(); // 等待循环计数器到达一个整数值
        System.out.println("Worker thread finished");
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample(3);

Thread workerThread1 = new Thread(example::workerThread);
        Thread workerThread2 = new Thread(example::workerThread);
        Thread workerThread3 = new Thread(example::workerThread);

// 启动所有工作线程
        workerThread1.start();
        workerThread2.start();
        workerThread3.start();

// 等待所有计数器都为0，即所有工作线程执行完毕
        barrier.await(); // 这里是等待，因为 barrier 的 wait 方法会让当前线程进入屏障区。

System.out.println("All threads finished");
    }
}
```
在这个例子中，`CyclicBarrier`用于协调多个工作线程的执行。当所有线程都调用`await()`时，循环计数器将增加到某个整数值，所有等待的线程都将被唤醒。