Java并發(fā)編程之CountDownLatch解讀

更新時間：2023年12月31日 09:07:40 作者：_Romeo

這篇文章主要介紹了Java并發(fā)編程之CountDownLatch解讀,是通過一個計數(shù)器來實現(xiàn)的,計數(shù)器的初始值是線程的數(shù)量,countDownLatch這個類使一個線程等待其他線程各自執(zhí)行完畢后再執(zhí)行,需要的朋友可以參考下

概念

countDownLatch這個類使一個線程等待其他線程各自執(zhí)行完畢后再執(zhí)行。
是通過一個計數(shù)器來實現(xiàn)的，計數(shù)器的初始值是線程的數(shù)量。每當一個線程執(zhí)行完畢后，計數(shù)器的值就-1，當計數(shù)器的值為0時，表示所有線程都執(zhí)行完畢，然后在閉鎖上等待的線程就可以恢復工作了。

源碼

countDownLatch類中只提供了一個構造器：

//參數(shù)count為計數(shù)值
public CountDownLatch(int count) {  };

類中有三個方法是最重要的：

//調用await()方法的線程會被掛起，它會等待直到count值為0才繼續(xù)執(zhí)行
public void await() throws InterruptedException { };   
//和await()類似，只不過等待一定的時間后count值還沒變?yōu)?的話就會繼續(xù)執(zhí)行
public boolean await(long timeout, TimeUnit unit) throws InterruptedException { };  
//將count值減1
public void countDown() { };

自定義實現(xiàn)一個CountDownLatch

代碼如下：

public class KaneCountDownLatch {
    private KaneCountDownLatch.Sync sync;
    public KaneCountDownLatch(int count) {
        this.sync = new KaneCountDownLatch.Sync(count);
    }
    public void countDown() {
        this.sync.releaseShared(1);
    }
    public void await() {
        this.sync.acquireShared(1);
    }
    class Sync extends AbstractQueuedSynchronizer {
        public Sync(int count) {
            this.setState(count);
        }
        protected int tryAcquireShared(int arg) {
            return this.getState() == 0 ? 1 : -1;
        }
        protected boolean tryReleaseShared(int arg) {
            int c;
            int nextc;
            do {
                c = this.getState();
                if (c == 0) {
                    return false;
                }
                nextc = c - 1;
            } while(!this.compareAndSetState(c, nextc));
            return nextc == 0;
        }
    }
}

測試代碼如下：

public class CountDownLatch_Demo {
    public static void main(String[] args) throws InterruptedException {
        KaneCountDownLatch latch = new KaneCountDownLatch(6); //計數(shù)為6
        for (int i = 0; i <6 ; i++) {
            new Thread(()->{
                System.out.println("開始準備.....");
                latch.countDown();//計數(shù)減一
            }).start();
            Thread.sleep(1000);
        }
        latch.await(); //每個線程執(zhí)行一次，則-1，在latch為0的時候開始向下運行 這是這些線程都準備就緒，然后去一起干同一件事
        //還有一種方式， 將一個活分為多段，每個線程去干一段
//        for (int i = 0; i <6 ; i++) {
//            new Thread(()->{
//                  latch.countDown(); // 計數(shù)減一
//                try {
//                    latch.await(); // 阻塞 -- > 0
//                    System.out.println("線程："+Thread.currentThread().getName()+"執(zhí)行完畢");
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
//            }).start();
//        }
        System.out.println("開始干活....");
    }
}