currtDownLatch可能会出现的三个问题

1. CountDownLatch无法归零，而导致主线程一直冗在那里

2. 已超出指定的等待时间

3. 其他某个线程中断当前线程

　　解决

　　

　　1,。CountDownLatch无法归零，而导致主线程一直冗在那里

　　

　　     @ 在写程序的时候，代码正确，能归零

　　 　@ 为了防止出现异常，将countDown放到finally里面，都会进行执行

　　　　

       @Override
        public void run() {
            try {
                function1();//执行代码
            } catch (Exception e) {
                //异常处理
                e.printStackTrace();
            }
            finally {
                countDownLatch.countDown();
            }
           // function1();
        }

　　2. 已超出指定的等待时间

　　　　CountDownLatch实例的await()，归避长时间阻塞线程的风险，任何多线程应用程序都有死锁风险

　　　　　　改用CountDownLatch实例的await(long timeout, TimeUnit unit)，设定超时时间，

　　　　如：CountDownLatch.await(20,TimeUnit.SECONDS);

　　

    try {
        //conutDownLatch.await();
        conutDownLatch.await(20,TimeUnit.SECONDS);
        System.out.println("执行线程结束");
    } catch (InterruptedException e) {
        e.printStackTrace();
        System.out.println("执行线程异常");
    }

　　　　public boolean await(long timeout, TimeUnit unit)
           　　　　throws InterruptedException

 

在利用 countDownLatch时，有时报 线程池满了，例如：在开两个线程开两个线程调用两个方法，在计算最后合并数据的步骤中

两个线程调用两个不同的方法时，使用countdownlatch 计数器等待三个方法全部执行完成 合并数据，其中方法1是调用接口，接口出错，导致此方法1没有完成。

 　　　　由于： 方法1调用异常后，没有处理异常导致不会执行线程关闭步骤（两个线程合并，线程关闭写在第二个方法里）

　　　　　　就像这样的场景导致线上service执行线程阻塞，接口调用次数累计导致dubbo线程满了

　　　　所以要将countDown放到finally里面，而且指定的等待时间await(long timeout, TimeUnit unit)

例子：

　　

public static void main(String[] args) {
    ExecutorService executorService =Executors.newFixedThreadPool(2);
    CountDownLatch cdl = new CountDownLatch(2);
    executorService.execute(new Runnable() {
        @Override
        public void run() {
            try {
                function1();
            } catch (Exception e) {
                //异常处理
                e.printStackTrace();
            }
            finally {
                cdl.countDown();
            }
           // function1();
        }
    });

    executorService.execute(new Runnable() {
        @Override
        public void run() {
            function2();
            cdl.countDown();
        }
    });



    try {
       // cdl.await();
        cdl.await(20,TimeUnit.SECONDS);
        System.out.println("二个执行线程结束");
    } catch (InterruptedException e) {
        e.printStackTrace();
        System.out.println("执行线程异常");
    }
    finally {
        executorService.shutdown();
        System.out.println("执行线程关闭");
    }


}

　　private static void function1(){
    　　int i = 1/0;
    　　System.out.println("方法一");
　　}　　

　　private static void function2(){
   　　 System.out.println("方法二");
53　　 }

API中当调用await时候，调用线程处于等待挂起状态，直至count变成0再继续。

其大体原理如下：

 

 

 

 

 

 

 

 

 

 

 

 

 

 

 

地址： https://blog.csdn.net/u010144805/article/details/79259024

https://blog.csdn.net/u010598327/article/details/82083038