CountDownLatch的理解和使用

CountDownLatch是Java中的一个并发工具类，用于实现线程等待的功能。它可以让一个或多个线程等待其他线程的操作完成后再继续执行。

CountDownLatch使用一个计数器来实现等待。计数器的初始值可以设置为一个正整数，当一个线程执行完自己的任务后，计数器的值减1。当计数器的值变为0时，所有等待的线程将被释放，可以继续执行。

CountDownLatch的主要方法包括：

CountDownLatch(int count)：构造方法，设置计数器的初始值。void await()：使当前线程等待，直到计数器的值变为0。void countDown()：计数器的值减1。

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

import java.util.concurrent.CountDownLatch;public class CountDownLatchExample {    public static void main(String[] args) throws InterruptedException {        CountDownLatch latch = new CountDownLatch(3);  // 设置计数器的初始值为3        Worker worker1 = new Worker(latch, "Worker1");        Worker worker2 = new Worker(latch, "Worker2");        Worker worker3 = new Worker(latch, "Worker3");        worker1.start();        worker2.start();        worker3.start();        latch.await();  // 等待所有线程执行完毕        System.out.println("All workers have finished their tasks.");    }}class Worker extends Thread {    private CountDownLatch latch;    public Worker(CountDownLatch latch, String name) {        super(name);        this.latch = latch;    }    public void run() {        try {            Thread.sleep(1000);  // 模拟任务执行时间            System.out.println(getName() + " has finished its task.");            latch.countDown();  // 计数器的值减1        } catch (InterruptedException e) {            e.printStackTrace();        }    }}

在上面的示例中，我们创建了一个CountDownLatch对象，并将其初始值设置为3。然后创建了三个Worker线程，并让它们执行任务。每个Worker线程执行完任务后，都会调用countDown()方法将计数器的值减1。主线程调用await()方法等待计数器的值变为0，即所有Worker线程都执行完任务后，主线程才会继续执行。

注意：CountDownLatch的计数器是一次性的，一旦计数器的值变为0，就无法重置为其他值。如果需要多次使用计数器，可以考虑使用CyclicBarrier类。