CountDownLatch，一個(gè)同步輔助類，在完成一組正在其他線程中執(zhí)行的操作之前，它允許一個(gè)或多個(gè)線程一直等待。

主要方法

?public CountDownLatch(int count);

?public void?countDown();

?public void?await() throws?InterruptedException

構(gòu)造方法參數(shù)指定了計(jì)數(shù)的次數(shù)

countDown方法，當(dāng)前線程調(diào)用此方法，則計(jì)數(shù)減一

awaint方法，調(diào)用此方法會(huì)一直阻塞當(dāng)前線程，直到計(jì)時(shí)器的值為0

例子：

public class CountDownLatchDemo { final static SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); public static void main(String[] args) throws InterruptedException { CountDownLatch latch=new CountDownLatch(2);//兩個(gè)工人的協(xié)作 Worker worker1=new Worker("zhang san", 5000, latch); Worker worker2=new Worker("li si", 8000, latch); worker1.start();// worker2.start();// latch.await();//等待所有工人完成工作 System.out.println("all work done at "+sdf.format(new Date())); } static class Worker extends Thread{ String workerName; int workTime; CountDownLatch latch; public Worker(String workerName ,int workTime ,CountDownLatch latch){ this.workerName=workerName; this.workTime=workTime; this.latch=latch; } public void run(){ System.out.println("Worker "+workerName+" do work begin at "+sdf.format(new Date())); doWork();//工作了 System.out.println("Worker "+workerName+" do work complete at "+sdf.format(new Date())); latch.countDown();//工人完成工作，計(jì)數(shù)器減一 } private void doWork(){ try { Thread.sleep(workTime); } catch (InterruptedException e) { e.printStackTrace(); } } } }

輸出：

Worker zhang san do work begin at 2011-04-14 11:05:11
Worker li si do work begin at 2011-04-14 11:05:11
Worker zhang san do work complete at 2011-04-14 11:05:16
Worker li si do work complete at 2011-04-14 11:05:19
all work done at 2011-04-14 11:05:19

?

CountDownLatch類有3個(gè)基本元素：

初始值決定CountDownLatch類需要等待的事件的數(shù)量。

await() 方法, 被等待全部事件終結(jié)的線程調(diào)用。

countDown() 方法，事件在結(jié)束執(zhí)行后調(diào)用。

當(dāng)創(chuàng)建 CountDownLatch 對(duì)象時(shí)，對(duì)象使用構(gòu)造函數(shù)的參數(shù)來(lái)初始化內(nèi)部計(jì)數(shù)器。每次調(diào)用 countDown() 方法, CountDownLatch 對(duì)象內(nèi)部計(jì)數(shù)器減一。當(dāng)內(nèi)部計(jì)數(shù)器達(dá)到0時(shí)， CountDownLatch 對(duì)象喚醒全部使用 await() 方法睡眠的線程們。

不可能重新初始化或者修改CountDownLatch對(duì)象的內(nèi)部計(jì)數(shù)器的值。一旦計(jì)數(shù)器的值初始后，唯一可以修改它的方法就是之前用的 countDown() 方法。當(dāng)計(jì)數(shù)器到達(dá)0時(shí)， 全部調(diào)用 await() 方法會(huì)立刻返回，接下來(lái)任何countDown() 方法的調(diào)用都將不會(huì)造成任何影響。

此方法與其他同步方法有這些不同：

CountDownLatch 機(jī)制不是用來(lái)保護(hù)共享資源或者臨界區(qū)。它是用來(lái)同步一個(gè)或者多個(gè)執(zhí)行多個(gè)任務(wù)的線程。它只能使用一次。像之前解說(shuō)的，一旦CountDownLatch的計(jì)數(shù)器到達(dá)0，任何對(duì)它的方法的調(diào)用都是無(wú)效的。如果你想再次同步，你必須創(chuàng)建新的對(duì)象。

CountDownLatch 類有另一種版本的 await() 方法，它是：

• await(long time, TimeUnit unit): 此方法會(huì)休眠直到被中斷； CountDownLatch 內(nèi)部計(jì)數(shù)器到達(dá)0或者特定的時(shí)間過(guò)去了。TimeUnit 類包含了:DAYS, HOURS, MICROSECONDS, MILLISECONDS, MINUTES, NANOSECONDS, 和 SECONDS.

轉(zhuǎn)載于:https://www.cnblogs.com/pypua/articles/7307648.html

總結(jié)

以上是生活随笔為你收集整理的java线程并发库之--线程同步工具CountDownLatch用法的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。