CountDownLatch有什么用？CountDownLatch的原理是什么？用过CountDownLatch么？什么场景下用的？

CountDownLatch是Java中的一个同步工具类，它可以让一个或多个线程等待其他线程完成操作后再执行。CountDownLatch的原理是通过一个计数器来实现的，当计数器的值为0时，等待的线程就可以继续执行了。使用CountDownLatch可以解决多个线程之间的协调问题，比如等待多个线程完成某个操作后再执行下一步操作。我曾经在一个多线程下载文件的场景中使用过CountDownLatch，通过设置计数器的初始值为下载线程的数量，每个线程下载完成后将计数器减1，当计数器的值为0时，主线程就可以继续执行下一步操作了。

相关问题

用过 CountDownLatch 么？什么场景下用的？

是的，CountDownLatch 是 Java 并发包中的一个类，它可以让一个或多个线程等待其他线程完成操作后再执行。它的作用是允许一个或多个线程等待其他线程完成操作后再继续执行。在 CountDownLatch 对象被创建时，需要指定计数器的初始值，当一个线程完成了其任务后，计数器的值会减 1，当计数器的值变为 0 时，处于等待状态的线程才会继续执行。

CountDownLatch 的场景是在一个线程等待多个线程执行完毕后再进行操作的情况下使用，例如某个线程需要等待多个子线程执行完毕后，再进行下一步操作。另外，CountDownLatch 还可以用于模拟并发请求的场景，例如在压测时可以使用 CountDownLatch 来控制并发请求的数量。

CyclicBarrier和CountDownLatch有什么区别？

CyclicBarrier和CountDownLatch是Java中的两个并发工具类，它们有以下区别：

1. 作用对象不同：CyclicBarrier作用于线程，要等待固定数量的线程都到达栅栏位置才能继续执行；而CountDownLatch作用于事件，只需等待数字倒数到0。

2. 执行动作不同：CyclicBarrier可以设置执行动作barrierAction，当所有线程都到达栅栏位置时，会执行这个动作；而CountDownLatch没有这个功能。

下面是一个使用CyclicBarrier和CountDownLatch的示例：

import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;

public class BarrierExample {
    public static void main(String[] args) {
        int threadCount = 3;
        
        // 使用CyclicBarrier
        CyclicBarrier cyclicBarrier = new CyclicBarrier(threadCount, () -> {
            System.out.println("所有线程都到达栅栏位置，开始执行barrierAction");
        });
        
        for (int i = 0; i < threadCount; i++) {
            new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getName() + " 到达栅栏位置");
                    cyclicBarrier.await();
                    System.out.println(Thread.currentThread().getName() + " 继续执行");
                } catch (InterruptedException | BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
        
        // 使用CountDownLatch
        CountDownLatch countDownLatch = new CountDownLatch(threadCount);
        
        for (int i = 0; i < threadCount; i++) {
            new Thread(() -> {
                try {
                    System.out.println(Thread.currentThread().getName() + " 执行任务");
                    countDownLatch.countDown();
                    countDownLatch.await();
                    System.out.println(Thread.currentThread().getName() + " 继续执行");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}