Java中的CountDownLatch

类声明

public class CountDownLatch
   extends Object

CountDownLatch类是一种同步辅助工具，它允许一个或多个线程等待直到其他线程执行了必需的操作。

• CountDownLatch用给定的线程数初始化，该线程数要求在主线程之前完成。

• CountDownLatch.await()方法阻止主线程执行，直到当前计数达到零为止。countDown()当线程完成任务时，通过执行线程使用方法来减少计数。一旦计数为0，任何等待呼叫都会立即返回。

CountDownLatch方法

以下是CountDownLatch类中可用的重要方法的列表。

示例

以下是解释CountDownLatch功能的示例-

import java.util.concurrent.CountDownLatch;

public class Tester {
   public static void main(String args[]) {
      //将计数器设置为2，即两个应用程序  
      CountDownLatch countDownLatch = new CountDownLatch(4);

      Thread app1 = new Thread(new Application("App1",  countDownLatch));
      Thread app2 = new Thread(new Application("App2",  countDownLatch));          
      Thread app3 = new Thread(new Application("App3",  countDownLatch));
      Thread app4 = new Thread(new Application("App4",  countDownLatch));  
 
      //初始化应用程序
      app1.start();
      app2.start();
      app3.start();
      app4.start();

      try {
         //等到countDownLatch减少到0。-
         countDownLatch.await();            
         //当所有应用程序启动时，打印消息
         System.out.println("所有应用程序都已启动并正在运行。");
      } catch(InterruptedException e) {
         System.out.println(e.getMessage());
      }        
   }
}

class Application implements Runnable {
   private String name;
   private CountDownLatch countDownLatch;

   public Application(String name, CountDownLatch countDownLatch) {
      this.name = name;
      this.countDownLatch = countDownLatch;
   }

   public void run() {
      try {
         System.out.println(name + " started. ");
         Thread.sleep(1000);
      } catch (InterruptedException e) {
         System.out.println(e.getMessage());
      }
      System.out.println( name + " 已启动并正在运行。");
      //将计数减少1-
      countDownLatch.countDown();    
   }
}

这将产生以下结果-

输出结果

App2 started.  
App3 started.  
App1 started.  
App4 started.  
App1 已启动并正在运行。
App3 已启动并正在运行。
App4 已启动并正在运行。
App2 已启动并正在运行。
所有应用程序都已启动并正在运行。