Java并发编程：CountDownLatch、CyclicBarrier等工具使用示例

原创矫情吗；* 2024-09-20 06:33 147阅读 0赞

Java的`CountDownLatch`, `CyclicBarrier`是两种常用的同步工具，用于多线程之间的协调和控制。

1. CountDownLatch

CountDownLatch用于一个或多个线程等待其他线程完成特定操作后释放计数器。当计数器为0时，所有等待的线程会一起唤醒。

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

public class CountDownLatchExample {
    private CountDownLatch countDownLatch;

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

// 线程1：计数，当计数为0时唤醒。
    public void thread1() throws InterruptedException {
        for (int i = 0; i < 5; i++) {
            countDownLatch.countDown(); // 减少计数
            System.out.println("Thread 1: " + i);
        }
        countDownLatch.await(); // 等待计数为0，唤醒
    }

// 线程2：等待线程1完成
    public void thread2() throws InterruptedException {
        countDownLatch.await(); // 等待线程1计数为0
        System.out.println("Thread 2: All done.");
    }

public static void main(String[] args) {
        CountDownLatchExample example = new CountDownLatchExample(5);
        new Thread(example::thread1).start();
        new Thread(example::thread2)).start();
    }
}
```

2. CyclicBarrier

CyclicBarrier用于一组等待某个事件完成后一起前进的线程。当第一个线程到达屏障时，所有后续到达的线程都会被阻塞，直到有线程成功通过屏障。

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

public class CyclicBarrierExample {
    private CyclicBarrier cyclicBarrier;

public CyclicBarrierExample(int barrierSize) {
        cyclicBarrier = new CyclicBarrier(barrierSize);
    }

// 线程1：到达屏障，阻塞后续线程。
    public void thread1() throws InterruptedException {
        try {
            cyclicBarrier.await(); // 等待通过屏障
            System.out.println("Thread 1: All done.");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

public static void main(String[] args) {
        CyclicBarrierExample example = new CyclicBarrierExample(5);
        new Thread(example::thread1)).start();
    }
}
```

以上就是Java并发编程中`CountDownLatch`和`CyclicBarrier`两种工具的使用示例。