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类。