快捷導(dǎo)航

Java CountDownLatch計(jì)數(shù)器與CyclicBarrier循環(huán)屏障

更新時(shí)間：2023年04月06日 08:33:03 作者：Alphathur

CountDownLatch是一種同步輔助，允許一個(gè)或多個(gè)線程等待其他線程中正在執(zhí)行的操作的ASET完成。它允許一組線程同時(shí)等待到達(dá)一個(gè)共同的障礙點(diǎn)

定義

CountDownLatch: A synchronization aid that allows one or more threads to wait until a set of operations being performed in other threads completes.

CyclicBarrier: A synchronization aid that allows a set of threads to all wait for each other to reach a common barrier point.

上述是Oracle官方定義。簡(jiǎn)單來(lái)說(shuō)

CountDownLatch：計(jì)數(shù)器，允許一個(gè)或多個(gè)線程等待，直到在其他線程中執(zhí)行的一組操作完成。

CyclicBarrier：循環(huán)屏障，它允許一組線程相互等待以達(dá)到一個(gè)共同的屏障點(diǎn)。

區(qū)別

CountDownLatch 是 AQS (AbstractQueuedSynchronizer) 的一員，但 CyclicBarrier 不是。
CountDownLatch 的使用場(chǎng)景中，有兩類(lèi)線程，一類(lèi)是調(diào)用await()方法的等待線程，另一類(lèi)是調(diào)用countDownl() 方法的操作線程。CyclicBarrier 的場(chǎng)景中，只有一類(lèi)線程，都是相互等待的等待線程。
CountDownLatch 是減計(jì)數(shù)，遞減完后不能復(fù)位，CyclicBarrier 是加計(jì)數(shù)，遞增完后自動(dòng)復(fù)位

CountDownLatch 示例

創(chuàng)建兩組線程，一組等待另一組執(zhí)行完才繼續(xù)進(jìn)行

CountDownLatch countDownLatch = new CountDownLatch(5);
ExecutorService executorService = Executors.newCachedThreadPool();
for (int i = 0; i < 5; i++) {
    executorService.execute(() -> {
        countDownLatch.countDown();
        System.out.println("run..");
    });
}
for (int i = 0; i < 3; i++) {  //我們要等上面執(zhí)行完成才繼續(xù)
    executorService.execute(() -> {
        try {
            countDownLatch.await();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("await..");
    });
}
executorService.shutdown();

打?。?/p>

run..
run..
run..
run..
run..
await..
await..
await..

等待累加線程執(zhí)行完，主線程再輸出累加結(jié)果

public class ThreadUnsafeExample {
    private int cnt = 0;
    public void add() {
        cnt++;
    }
    public int get() {
        return cnt;
    }
    public static void main(String[] args) throws InterruptedException {
        final int threadSize = 1000;
        ThreadUnsafeExample example = new ThreadUnsafeExample();
        final CountDownLatch countDownLatch = new CountDownLatch(threadSize);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < threadSize; i++) {
            executorService.execute(() -> {
                example.add();
                countDownLatch.countDown();
            });
        }
        countDownLatch.await();
        executorService.shutdown();
        System.out.println(example.get());
    }
}

打?。?/p>

997

3 模擬并發(fā)

ExecutorService executorService = Executors.newCachedThreadPool();
        CountDownLatch countDownLatch = new CountDownLatch(1);
        for (int i = 0; i < 5; i++) {
            executorService.submit( () -> {
                try {
                    countDownLatch.await();
                    System.out.println("【" + Thread.currentThread().getName() + "】開(kāi)始執(zhí)行……");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            });
        }
        Thread.sleep(2000);
        countDownLatch.countDown();//開(kāi)始并發(fā)
        executorService.shutdown();

打?。?/p>

【pool-2-thread-2】開(kāi)始執(zhí)行……
【pool-2-thread-5】開(kāi)始執(zhí)行……
【pool-2-thread-3】開(kāi)始執(zhí)行……
【pool-2-thread-1】開(kāi)始執(zhí)行……
【pool-2-thread-4】開(kāi)始執(zhí)行……

CyclicBarrier 示例

所有線程相互等待，直到某一步完成后再繼續(xù)執(zhí)行

        final int totalThread = 3;
        CyclicBarrier cyclicBarrier = new CyclicBarrier(3);
        ExecutorService executorService = Executors.newCachedThreadPool();
        for (int i = 0; i < totalThread; i++) {
            executorService.execute(() -> {
                System.out.println("before..");
                try {
                    cyclicBarrier.await();
                } catch (InterruptedException | BrokenBarrierException e) {
                    e.printStackTrace();
                }
                System.out.println("after..");
            });
        }
        executorService.shutdown();

打?。?/p>

before..
before..
before..
after..
after..
after..

到此這篇關(guān)于Java CountDownLatch計(jì)數(shù)器與CyclicBarrier循環(huán)屏障的文章就介紹到這了,更多相關(guān)Java CountDownLatch與CyclicBarrier內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: