快捷導(dǎo)航

JAVA多線程CountDownLatch使用詳解

更新時(shí)間：2021年04月20日 15:27:08 作者：隊(duì)長(zhǎng)給我球。

這篇文章主要為大家詳細(xì)介紹了JAVA多線程CountDownLatch的使用，文中示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下

前序:

上周測(cè)試給開發(fā)的同事所開發(fā)的模塊提出了一個(gè)bug，并且還是偶現(xiàn)。

經(jīng)過仔細(xì)查看代碼，發(fā)現(xiàn)是在業(yè)務(wù)中啟用了多線程，2個(gè)線程同時(shí)跑，但是新啟動(dòng)的2個(gè)線程必須保證一個(gè)完成之后另一個(gè)再繼續(xù)運(yùn)行，才能消除bug。

什么時(shí)候用？

多線程是在很多地方都會(huì)用到的，但是我們?nèi)绻胍獙?shí)現(xiàn)在某個(gè)特定的線程運(yùn)行完之后，再啟動(dòng)另外一個(gè)線程呢，這個(gè)時(shí)候CountDownLatch就可以派上用場(chǎng)了

怎么用？

先看看普通的多線程代碼：

package code;

public class MyThread extends Thread { 
  public static void main(String[] args) {   
    MyThread th = new MyThread();  
    Thread t1 = new Thread(th, "Mythread");    
    t1.start(); 
    System.out.println(Thread.currentThread().getName()); 
    }    
    public void run() 
      {   
        Mythread1 th2 = new Mythread1();  
        Thread t2 = new Thread(th2, "Mythread1");    
        t2.start(); 
        System.out.println(this.currentThread().getName()); 
      } 
    class Mythread1 extends Thread
    {
      public void run() {  
        try {
          Thread.sleep(1000);
        } catch (InterruptedException e) {
          // TODO Auto-generated catch block
          e.printStackTrace();
        }
        System.out.println(this.currentThread().getName()); 
        } 
      
    }
  }

代碼如上，先用MyThread繼承了Thread類，然后在MyThread類內(nèi)部又寫了一個(gè)MyThread1類，同樣也是繼承了Thread類，并且在run方法里面讓它睡1秒，這樣運(yùn)行代碼，就會(huì)打印出：

從上面的輸出順序可以看出，先是啟動(dòng)了main線程，然后再啟動(dòng)了MyThread線程，在MyThread線程中，又啟動(dòng)了MyThread1線程。但是由于讓MyThread1線程睡了1秒，模擬處理后續(xù)業(yè)務(wù)，這樣他就比MyThread運(yùn)行完畢的時(shí)間晚一些。

現(xiàn)在，在代碼中加上CountDownLatch ，要讓MyThread1先運(yùn)行完畢，再讓MyThread繼續(xù)運(yùn)行。

package code;

import java.util.concurrent.CountDownLatch;

public class MyThread extends Thread { 
  CountDownLatch countDownLatch = new CountDownLatch(1);
  public static void main(String[] args) {   
    MyThread th = new MyThread();  
    Thread t1 = new Thread(th, "Mythread");    
    t1.start(); 
    System.out.println(Thread.currentThread().getName()); 
    }    
    public void run() 
      {   
        Mythread1 th2 = new Mythread1();  
        Thread t2 = new Thread(th2, "Mythread1");    
        t2.start(); 
        try {
          countDownLatch.await();
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        System.out.println(this.currentThread().getName()); 
      } 
    class Mythread1 extends Thread
    {
      public void run() {  
        try {
          Thread.sleep(1000);
        } catch (InterruptedException e) {
          e.printStackTrace();
        }
        System.out.println(this.currentThread().getName()); 
        countDownLatch.countDown();
        } 
      
    }
  }

代碼寫法如上所示，大致分三步

1、我們先new一個(gè)CountDownLatch對(duì)象入?yún)⒃O(shè)置為1（我個(gè)人理解的這個(gè)就像是new一個(gè)數(shù)組一樣，什么時(shí)候數(shù)組清空了，那就可以讓被中斷的線程繼續(xù)運(yùn)行了）

2、在MyThread類中調(diào)用countDownLatch.await();讓當(dāng)前線程停止運(yùn)行。

3、在Mythread1類中調(diào)用countDownLatch.countDown()方法。當(dāng)Mythread1全部執(zhí)行完畢，再最后調(diào)用該方法，作用就是把我說的“數(shù)組”清空。

看看輸出的打印結(jié)果