CountDownLatch了解

           CountDownLatch在java.util.concurrent.CountDownLatch包里面，他通常用在多线程中，假如说我们现在有一件事情开了多线程去完成，但是我们需要保证所有的线程都成功运行结束，再去执行后面的代码，这个时候CountDownLatch这个类就派上用场了。

创新互联专注为客户提供全方位的互联网综合服务，包含不限于网站设计制作、成都网站制作、嘉鱼网络推广、微信小程序开发、嘉鱼网络营销、嘉鱼企业策划、嘉鱼品牌公关、搜索引擎seo、人物专访、企业宣传片、企业代运营等，从售前售中售后，我们都将竭诚为您服务，您的肯定，是我们最大的嘉奖；创新互联为所有大学生创业者提供嘉鱼建站搭建服务，24小时服务热线：028-86922220，官方网址：www.cdcxhl.com

我们可以把CountDownLatch传入到每个线程里面去，在线程执行成功时调用countDownLatch.countDown();方法，然后在主线程里面执行完多线程初始化和分发执行之后执行countDownLatch.await();这样，只有在每个线程执行成功以后，也就是CountDownLatch的计数器减到0以后，才会执行countDownLatch.await()后面的代码。

简单的应用场景是这样的，但是具体的怎么设计还是需要仔细斟酌，否则有可能会出现countDownLatch.countDown();永远无法减为0的情况。

 

下面一个简单的例子来实现这一应用场景：

---

package org.hzg.countDownLatch; import java.util.concurrent.CountDownLatch; /** * Created by hzgal on 2019-3-5. */ public abstract class DangerCenter implements Runnable {    private CountDownLatch countDownLatch;      //计数器    private String station;                      //危险品调度站    private boolean isOkToSentCar;              //检查结果，是否满足发车条件    public DangerCenter(CountDownLatch countDownLatch,String stationName) {        this.countDownLatch = countDownLatch;        this.station = stationName;        this.isOkToSentCar = false;    }    @Override    public void run() {        try {            check();            isOkToSentCar = true;        }catch (Exception e) {            e.printStackTrace();            isOkToSentCar = false;        }finally {            if(countDownLatch != null) {                countDownLatch.countDown();            }        }    }    /**     * 定义抽象的check方法，用于实现了DangerCenter的各级调度中心来重写check方法，因为每个调度中心自检的方法可能不一样     */    public abstract void check();    public CountDownLatch getCountDownLatch() {        return countDownLatch;    }    public void setCountDownLatch(CountDownLatch countDownLatch) {        this.countDownLatch = countDownLatch;    }    public String getStation() {        return station;    }    public void setStation(String station) {        this.station = station;    }    public boolean isOkToSentCar() {        return isOkToSentCar;    }    public void setOkToSentCar(boolean okToSentCar) {        isOkToSentCar = okToSentCar;    } }

package org.hzg.countDownLatch; import java.util.concurrent.CountDownLatch; /** * Created by hzgal on 2019-3-5. */ public class BeijingStation extends DangerCenter {    private static String stationName = "北京危险品调度站";    public BeijingStation(CountDownLatch countDownLatch) {        super(countDownLatch,stationName);    }    @Override    public void check() {        System.out.println("北京调度站正在进行车辆自检..........");        try {            Thread.sleep(2000);        }catch (Exception e) {            e.printStackTrace();        }        System.out.println("北京调度站车辆自检完毕，一切正常");    } }

package org.hzg.countDownLatch; import java.util.concurrent.CountDownLatch; /** * Created by hzgal on 2019-3-5. */ public class ShandongStation extends DangerCenter {    private static String stationName = "山东危险品调度站";    public ShandongStation(CountDownLatch countDownLatch) {        super(countDownLatch,stationName);    }    @Override    public void check() {        System.out.println("山东调度站正在进行车辆自检..........");        try {            Thread.sleep(1000);        }catch (Exception e) {            e.printStackTrace();        }        System.out.println("山东调度站车辆自检完毕，一切正常");    } }

package org.hzg.countDownLatch; import java.util.concurrent.CountDownLatch; /** * Created by hzgal on 2019-3-5. */ public class ShanxiStation extends DangerCenter {    private static String stationName = "陕西危险品调度站";    public ShanxiStation(CountDownLatch countDownLatch) {        super(countDownLatch,stationName);    }    @Override    public void check() {        System.out.println("陕西调度站正在进行车辆自检..........");        try {            Thread.sleep(3000);        }catch (Exception e) {            e.printStackTrace();        }        System.out.println("陕西调度站车辆自检完毕，一切正常");    } }

package org.hzg.countDownLatch; import java.util.ArrayList; import java.util.LinkedList; import java.util.List; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Executor; import java.util.concurrent.Executors; /** * Created by hzgal on 2019-3-5. */ public class Demo {    public static void main(String[] args) {        boolean isAllOk = true;        List stationList = new ArrayList();        CountDownLatch countDownLatch = new CountDownLatch(3);        stationList.add(new BeijingStation(countDownLatch));        stationList.add(new ShandongStation(countDownLatch));        stationList.add(new ShanxiStation(countDownLatch));        Executor stationThreadPool = Executors.newFixedThreadPool(3);        for(DangerCenter stationCenter : stationList) {            stationThreadPool.execute(stationCenter);        }        try {            countDownLatch.await();        }catch (Exception e) {            e.printStackTrace();        }        for(DangerCenter stationCenter : stationList) {            if(!stationCenter.isOkToSentCar()) {                isAllOk = false;            }        }        if (isAllOk) {            System.out.println("所有站点检查完毕，可以正常进行发车！！！！！！！！！");        }    } }

程序运行结果： 北京调度站正在进行车辆自检.......... 山东调度站正在进行车辆自检.......... 陕西调度站正在进行车辆自检.......... 山东调度站车辆自检完毕，一切正常 北京调度站车辆自检完毕，一切正常 陕西调度站车辆自检完毕，一切正常 所有站点检查完毕，可以正常进行发车！！！！！！！！！

新闻名称：CountDownLatch了解
文章转载：http://bjjierui.cn/article/ihscig.html