1. CountDownLatch無(wú)法歸零，而導(dǎo)致主線程一直冗在那里

2. 已超出指定的等待時(shí)間

3. 其他某個(gè)線程中斷當(dāng)前線程

　　解決

　　

　　1,。CountDownLatch無(wú)法歸零，而導(dǎo)致主線程一直冗在那里

　　

　　 @ 在寫(xiě)程序的時(shí)候，代碼正確，能歸零

　　 　@ 為了防止出現(xiàn)異常，將countDown放到finally里面，都會(huì)進(jìn)行執(zhí)行

　　　　

 1        @Override
 2         public void run() {
 3             try {
 4                 function1();//執(zhí)行代碼
 5             } catch (Exception e) {
 6                 //異常處理
 7                 e.printStackTrace();
 8             }
 9             finally {
10                 countDownLatch.countDown();
11             }
12            // function1();
13         }

　　2. 已超出指定的等待時(shí)間

　　　　CountDownLatch實(shí)例的await()，歸避長(zhǎng)時(shí)間阻塞線程的風(fēng)險(xiǎn)，任何多線程應(yīng)用程序都有死鎖風(fēng)險(xiǎn)

　　　　　　改用CountDownLatch實(shí)例的await(long timeout, TimeUnit unit)，設(shè)定超時(shí)時(shí)間，

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

　　

1     try {
2         //conutDownLatch.await();
3         conutDownLatch.await(20,TimeUnit.SECONDS);
4         System.out.println("執(zhí)行線程結(jié)束");
5     } catch (InterruptedException e) {
6         e.printStackTrace();
7         System.out.println("執(zhí)行線程異常");
8     }

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

在利用 countDownLatch時(shí)，有時(shí)報(bào) 線程池滿了，例如：在開(kāi)兩個(gè)線程開(kāi)兩個(gè)線程調(diào)用兩個(gè)方法，在計(jì)算最后合并數(shù)據(jù)的步驟中

兩個(gè)線程調(diào)用兩個(gè)不同的方法時(shí)，使用countdownlatch 計(jì)數(shù)器等待三個(gè)方法全部執(zhí)行完成 合并數(shù)據(jù)，其中方法1是調(diào)用接口，接口出錯(cuò)，導(dǎo)致此方法1沒(méi)有完成。

　　　　由于： 方法1調(diào)用異常后，沒(méi)有處理異常導(dǎo)致不會(huì)執(zhí)行線程關(guān)閉步驟（兩個(gè)線程合并，線程關(guān)閉寫(xiě)在第二個(gè)方法里）

　　　　　　就像這樣的場(chǎng)景導(dǎo)致線上service執(zhí)行線程阻塞，接口調(diào)用次數(shù)累計(jì)導(dǎo)致dubbo線程滿了

　　　　所以要將countDown放到finally里面，而且指定的等待時(shí)間await(long timeout, TimeUnit unit)

例子：

　　

 1 public static void main(String[] args) {
 2     ExecutorService executorService =Executors.newFixedThreadPool(2);
 3     CountDownLatch cdl = new CountDownLatch(2);
 4     executorService.execute(new Runnable() {
 5         @Override
 6         public void run() {
 7             try {
 8                 function1();
 9             } catch (Exception e) {
10                 //異常處理
11                 e.printStackTrace();
12             }
13             finally {
14                 cdl.countDown();
15             }
16            // function1();
17         }
18     });
19 
20     executorService.execute(new Runnable() {
21         @Override
22         public void run() {
23             function2();
24             cdl.countDown();
25         }
26     });
27 
28 
29 
30     try {
31        // cdl.await();
32         cdl.await(20,TimeUnit.SECONDS);
33         System.out.println("二個(gè)執(zhí)行線程結(jié)束");
34     } catch (InterruptedException e) {
35         e.printStackTrace();
36         System.out.println("執(zhí)行線程異常");
37     }
38     finally {
39         executorService.shutdown();
40         System.out.println("執(zhí)行線程關(guān)閉");
41     }
42 
43 
44 }
45 
46 　　private static void function1(){
47     　　int i = 1/0;
48     　　System.out.println("方法一");
49 　　}　　
50 
51 　　private static void function2(){
52    　　 System.out.println("方法二");
53　　 }

API中當(dāng)調(diào)用await時(shí)候，調(diào)用線程處于等待掛起狀態(tài)，直至count變成0再繼續(xù)。

其大體原理如下：

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

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

總結(jié)

以上是生活随笔為你收集整理的currtDownLatch可能会出现的三个问题的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

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