CountDownLatch 机制 实现

CountDownLatch 是 Java 提供的一种多线程同步机制，用于等待一组线程完成特定任务后再继续执行。下面是使用 CountDownLatch 实现多线程同步的基本步骤：

1. 创建 CountDownLatch 对象，并指定计数器的初始值。计数器表示需要等待的线程数量。

CountDownLatch latch = new CountDownLatch(N); // N为需要等待的线程数量

2. 在需要等待的线程中调用 `await()` 方法进行等待，直到计数器减到 0。

try {
    latch.await(); // 等待计数器减到0
} catch (InterruptedException e) {
    // 处理中断异常
}

3. 在任务完成的线程中调用 `countDown()` 方法，每次调用计数器减1。

latch.countDown(); // 任务完成，计数器减1

4. 可选地，在等待的线程中设置超时时间，以防止无限等待。

try {
    latch.await(timeout, TimeUnit.MILLISECONDS); // 设置超时时间
} catch (InterruptedException e) {
    // 处理中断异常
}

通过适当地设置计数器初始值和在任务完成时调用 `countDown()` 方法，可以实现多个线程之间的同步等待。一旦计数器减到 0，所有等待的线程将被唤醒继续执行。

注意，CountDownLatch 在计数器减到 0 之后无法重置，如果需要重复使用，可以考虑使用 CyclicBarrier 或 Phaser 等其他多线程同步机制。此外，确保在所有线程完成之前，适当地设置计数器初始值，否则可能会导致等待线程一直阻塞。