快捷導(dǎo)航

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

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

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

概念

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

源碼

countDownLatch類中只提供了一個(gè)構(gòu)造器：

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

類中有三個(gè)方法是最重要的：

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

自定義實(shí)現(xiàn)一個(gè)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;
        }
    }
}

測(cè)試代碼如下：

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

CountDownLatch和CyclicBarrier區(qū)別

countDownLatch是一個(gè)計(jì)數(shù)器，線程完成一個(gè)記錄一個(gè)，計(jì)數(shù)器遞減，只能只用一次
CyclicBarrier的計(jì)數(shù)器更像一個(gè)閥門，需要所有線程都到達(dá)，然后繼續(xù)執(zhí)行，計(jì)數(shù)器遞增，提供reset功能，可以多次使用

到此這篇關(guān)于Java并發(fā)編程之CountDownLatch解讀的文章就介紹到這了,更多相關(guān)CountDownLatch解讀內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: