1、使用場(chǎng)景

通過(guò)使用 CountDownLatch可以使當(dāng)前線程阻塞，等待其他線程完成給定任務(wù)。可以類(lèi)比旅游團(tuán)導(dǎo)游要等待所有的游客到齊后才能去下一個(gè)景點(diǎn)。

CountDownLatch 主要應(yīng)用場(chǎng)景：一個(gè)線程等待多個(gè)線程完成給定任務(wù)后，然后執(zhí)行后續(xù)的操作的場(chǎng)景。

2、使用介紹

CountDownLatch的構(gòu)造函數(shù)接收一個(gè)int類(lèi)型的參數(shù)作為計(jì)數(shù)器，如果你想等待N個(gè)點(diǎn)完 成，這里就傳入N。

這里所說(shuō)的N個(gè) 點(diǎn)，可以是N個(gè)線程，也可以是1個(gè)線程里的N個(gè)執(zhí)行步驟。CountDownLatch構(gòu)造函數(shù)如下：

public CountDownLatch(int count) {
        if (count < 0) throw new IllegalArgumentException("count < 0");
        this.sync = new Sync(count);
 }

計(jì)數(shù)器參數(shù)count必須大于等于0，等于0的時(shí)候，調(diào)用await方法時(shí)不會(huì) 阻塞當(dāng)前線程。

當(dāng)我們調(diào)用CountDownLatch的countDown()方法時(shí)，N就會(huì)減1，CountDownLatch的await()方法 會(huì)阻塞當(dāng)前線程，直到N變成零。

CountDownLatch 方法

• await() 阻塞當(dāng)前線程，直到計(jì)數(shù)器為零為止；
• await(long timeout, TimeUnit unit) await()的重載方法，可以指定阻塞時(shí)長(zhǎng)；
• countDown() 計(jì)數(shù)器減1，如果計(jì)數(shù)達(dá)到零，釋放所有等待的線程。
• getCount() 返回當(dāng)前計(jì)數(shù)

3、使用案例

使用多線程下載網(wǎng)絡(luò)上圖片，現(xiàn)在完成后，提示用戶下載完成。

public class DownLoadWorker implements Runnable{
    private String url;
    private  CountDownLatch countDownLatch;

    public DownLoadWorker(String url, CountDownLatch countDownLatch) {
        this.url = url;
        this.countDownLatch = countDownLatch;
    }

    @Override
    public void run() {
        //省略無(wú)數(shù)業(yè)務(wù)代碼
        System.out.println("線程" + Thread.currentThread().getName() + "開(kāi)始下載完成");
        countDownLatch.countDown();
    }
}

public static void main(String[] args) throws InterruptedException {
        CountDownLatch countDownLatch=new CountDownLatch(5);
        //使用Stream 生成5個(gè)線程
        List<Thread> workers = Stream
                .generate(() -> new Thread(new DownLoadWorker("https://image.baidu.com/", countDownLatch)))
                .limit(5)
                .collect(toList());
        //運(yùn)行線程
        workers.forEach(Thread::start);
        //等待線程完成
        countDownLatch.await();
        System.out.println("圖片已下載完~~~");
}

4、 Thread.join()和CountDownLatch的區(qū)別

Thread.join()是Thread類(lèi)的一個(gè)方法，Thread.join()的實(shí)現(xiàn)是依靠Object的wait()和notifyAll()來(lái)完成的，而CountDownLatch是JUC包中的一個(gè)工具類(lèi)。

當(dāng)我們使用ExecutorService ，就不能使用join，必須使用CountDownLatch比如：

ExecutorService service = Executors.newFixedThreadPool(5);
final CountDownLatch latch = new CountDownLatch(5);
for(int x = 0; x < 5; x++) {
    service.submit(new Runnable() {
        public void run() {
            // do something
            latch.countDown();
        }
    });
}
latch.await();

調(diào)用join方法需要等待thread執(zhí)行完畢才能繼續(xù)向下執(zhí)行，而CountDownLatch只需要檢查計(jì)數(shù)器的值為零就可以繼續(xù)向下執(zhí)行，相比之下，CountDownLatch更加靈活一些，可以實(shí)現(xiàn)一些更加復(fù)雜的業(yè)務(wù)場(chǎng)景。

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

最新評(píng)論