快捷導(dǎo)航

Java多線程編程之CountDownLatch同步工具使用實例

更新時間：2015年05月19日 10:12:24 投稿：junjie

這篇文章主要介紹了Java多線程編程之CountDownLatch同步工具使用實例,需要的朋友可以參考下

好像倒計時計數(shù)器，調(diào)用CountDownLatch對象的countDown方法就將計數(shù)器減1，當?shù)竭_0時，所有等待者就開始執(zhí)行。

java.util.concurrent.CountDownLatch
一個同步輔助類，在完成一組正在其他線程中執(zhí)行的操作之前，它允許一個或多個線程一直等待。用給定的計數(shù)初始化CountDownLatch。由于調(diào)用了countDown()方法，所以在當前計數(shù)到達零之前，await方法會一直受阻塞。之后，會釋放所有等待的線程，await的所有后續(xù)調(diào)用都將立即返回。這種現(xiàn)象只出現(xiàn)一次——計數(shù)無法被重置。如果需要重置計數(shù)，請考慮使用CyclicBarrier。

CountDownLatch是一個通用同步工具，它有很多用途。將計數(shù)1初始化的CountDownLatch用作一個簡單的開/關(guān)鎖存器，或入口：在通過調(diào)用countDown()的線程打開入口前，所有調(diào)用await的線程都一直在入口處等待。用N初始化的 CountDownLatch可以使一個線程在N個線程完成某項操作之前一直等待，或者使其在某項操作完成N次之前一直等待。

CountDownLatch的一個有用特性是，它不要求調(diào)用countDown方法的線程等到計數(shù)到達零時才繼續(xù)，而在所有線程都能通過之前，它只是阻止任何線程繼續(xù)通過一個await。

舉例：多個運動員等待裁判命令：裁判等所有運動員到齊后發(fā)布結(jié)果

package com.ljq.test.thread;
 
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
 
public class CountdownLatchTest {
 
  public static void main(String[] args) {
    ExecutorService service = Executors.newCachedThreadPool();
    //裁判發(fā)布命令的計數(shù)器，計數(shù)器為0，運動員就跑
    final CountDownLatch cdOrder = new CountDownLatch(1);
    //運動員跑到終點的計數(shù)器，為0裁判宣布結(jié)果
    final CountDownLatch cdAnswer = new CountDownLatch(3); 
     
    //產(chǎn)生3個運動員
    for(int i=0;i<3;i++){
      Runnable runnable = new Runnable(){
          public void run(){
          try {
            System.out.println("線程" + Thread.currentThread().getName() + "正準備接受命令");            
            cdOrder.await();
            System.out.println("線程" + Thread.currentThread().getName() + "已接受命令");               
            Thread.sleep((long)(Math.random()*10000)); 
            System.out.println("線程" + Thread.currentThread().getName() + "回應(yīng)命令處理結(jié)果");           
            cdAnswer.countDown();           
          } catch (Exception e) {
            e.printStackTrace();
          }       
        }
      };
      service.execute(runnable); //運動員開始任務(wù)
    }   
     
     
    try {
      //裁判休息一會 再發(fā)布命令
      Thread.sleep((long)(Math.random()*10000));
     
      System.out.println("線程" + Thread.currentThread().getName() + "即將發(fā)布命令");          
      cdOrder.countDown(); //命令計數(shù)器置為0，發(fā)布命令
      System.out.println("線程" + Thread.currentThread().getName() + "已發(fā)送命令，正在等待結(jié)果"); 
      cdAnswer.await(); //等待所有運動員，計數(shù)器為0 所有運動員到位
      System.out.println("線程" + Thread.currentThread().getName() + "已收到所有響應(yīng)結(jié)果"); 
    } catch (Exception e) {
      e.printStackTrace();
    }       
    service.shutdown();
 
  }
}

返回結(jié)果：

線程pool-1-thread-3正準備接受命令
線程pool-1-thread-1正準備接受命令
線程pool-1-thread-2正準備接受命令
線程main即將發(fā)布命令
線程main已發(fā)送命令，正在等待結(jié)果
線程pool-1-thread-2已接受命令
線程pool-1-thread-1已接受命令
線程pool-1-thread-3已接受命令
線程pool-1-thread-3回應(yīng)命令處理結(jié)果
線程pool-1-thread-2回應(yīng)命令處理結(jié)果
線程pool-1-thread-1回應(yīng)命令處理結(jié)果
線程main已收到所有響應(yīng)結(jié)果

您可能感興趣的文章: