Java CountDownLatch與CyclicBarrier及Semaphore使用教程

更新時(shí)間：2023年01月04日 08:34:48 作者：欲無緣

對(duì)于并發(fā)執(zhí)行，Java中的CountDownLatch是一個(gè)重要的類。為了更好的理解CountDownLatch這個(gè)類，本文將通過例子和源碼帶領(lǐng)大家深入解析CountDownLatch與CyclicBarrier及Semaphore的原理，感興趣的可以學(xué)習(xí)一下

CountDownLatch

CountDownLatch是一個(gè)倒數(shù)的計(jì)數(shù)器閥門，初始化時(shí)閥門關(guān)閉，指定計(jì)數(shù)的數(shù)量，當(dāng)數(shù)量倒數(shù)減到0時(shí)閥門打開，被阻塞線程被喚醒。

public class CountDownLatchDemo {
    public static void main(String[] args) throws InterruptedException {
    // 總數(shù)是6，必須要執(zhí)行任務(wù)的時(shí)候，再使用    ！
    CountDownLatch countDownLatch = new CountDownLatch(6);
    for (int i = 1; i <=6 ; i++) {    
        new Thread(()->{
        System.out.println(Thread.currentThread().getName()+" Go out");
        countDownLatch.countDown(); // 數(shù)量-1
        },String.valueOf(i)).start();
    }  
    countDownLatch.await(); // 等待計(jì)數(shù)器歸零，然后再向下執(zhí)行
    System.out.println("Close Door");
    }
}

原理

countDownLatch.countDown();//數(shù)量-1

countDownLatch.await();//等待

每次有線程調(diào)用 countDown() 數(shù)量-1，假設(shè)計(jì)數(shù)器變?yōu)?，countDownLatch.await() 就會(huì)被喚醒，繼續(xù)執(zhí)行！

CyclicBarrier

CyclicBarrier是一個(gè)可循環(huán)的屏障，它允許多個(gè)線程在執(zhí)行完相應(yīng)的操作后彼此等待共同到達(dá)一個(gè)point，等所有線程都到達(dá)后再繼續(xù)執(zhí)行。

CyclicBarrier也可以像CountDownLatch一樣適用于多個(gè)子任務(wù)并發(fā)執(zhí)行，當(dāng)所有子任務(wù)都執(zhí)行完后再繼續(xù)接下來的工作。

public class CyclicBarrierDemo {
    public static void main(String[] args) {
         // 召喚龍珠的線程
        CyclicBarrier cyclicBarrier = new CyclicBarrier(7,()->{
            System.out.println("召喚神龍成功！");
        });
        for (int i = 1; i <=7 ; i++) {
            final int temp = i;
            // lambda能操作到 i 嗎
            new Thread(()->{
                System.out.println(Thread.currentThread().getName()+"收集"+temp+"個(gè)龍珠");
                try {
                cyclicBarrier.await(); // 等待
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } catch (BrokenBarrierException e) {
                    e.printStackTrace();
                }
            }).start();
        }
    }
}

Semaphore

Semaphore翻譯過來是信號(hào)量的意思，它的作用是控制多個(gè)線程對(duì)同一個(gè)資源的訪問線程數(shù)量。比如在停車場(chǎng)停車，里面有10個(gè)車位，當(dāng)這10個(gè)車位被停滿的時(shí)候其他的車只能等待（堵塞）里面有車駛出（release）然后再進(jìn)入。

public class SemaphoreDemo {
    public static void main(String[] args) {
        // 線程數(shù)量：停車位! 限流！
        Semaphore semaphore = new Semaphore(3);
        for (int i = 1; i <=6 ; i++) {
            new Thread(()->{
            // acquire() 得到
            try {
                semaphore.acquire();
                System.out.println(Thread.currentThread().getName()+"搶到車位");
                TimeUnit.SECONDS.sleep(2);
                System.out.println(Thread.currentThread().getName()+"離開車位");
            } catch (InterruptedException e) {
                e.printStackTrace();
            } finally {
                semaphore.release(); // release() 釋放
            }
        },String.valueOf(i)).start();
        }
    }
}

semaphore.acquire();獲得，假設(shè)如果已經(jīng)滿了，等待，等待被釋放為止！

semaphore.release();釋放，會(huì)將當(dāng)前的信號(hào)量釋放 + 1，然后喚醒等待的線程！

作用：多個(gè)共享資源互斥的使用！并發(fā)限流，控制最大的線程數(shù)！

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

您可能感興趣的文章: