CountDownLatch有哪些用法

本篇內(nèi)容主要講解“CountDownLatch有哪些用法”，感興趣的朋友不妨來(lái)看看。本文介紹的方法操作簡(jiǎn)單快捷，實(shí)用性強(qiáng)。下面就讓小編來(lái)帶大家學(xué)習(xí)“CountDownLatch有哪些用法”吧!

CountDownLatch是一個(gè)同步工具類，用來(lái)協(xié)調(diào)多個(gè)線程之間的同步，或者說(shuō)起到線程之間的通信（而不是用作互斥的作用）。

CountDownLatch能夠使一個(gè)線程在等待另外一些線程完成各自工作之后，再繼續(xù)執(zhí)行。使用一個(gè)計(jì)數(shù)器進(jìn)行實(shí)現(xiàn)。計(jì)數(shù)器初始值為線程的數(shù)量。當(dāng)每一個(gè)線程完成自己任務(wù)后，計(jì)數(shù)器的值就會(huì)減一。當(dāng)計(jì)數(shù)器的值為0時(shí)，表示所有的線程都已經(jīng)完成一些任務(wù)，然后在CountDownLatch上等待的線程就可以恢復(fù)執(zhí)行接下來(lái)的任務(wù)。

CountDownLatch的用法

CountDownLatch典型用法：1、某一線程在開(kāi)始運(yùn)行前等待n個(gè)線程執(zhí)行完畢。將CountDownLatch的計(jì)數(shù)器初始化為new CountDownLatch(n)，每當(dāng)一個(gè)任務(wù)線程執(zhí)行完畢，就將計(jì)數(shù)器減1 countdownLatch.countDown()，當(dāng)計(jì)數(shù)器的值變?yōu)?時(shí)，在CountDownLatch上await()的線程就會(huì)被喚醒。一個(gè)典型應(yīng)用場(chǎng)景就是啟動(dòng)一個(gè)服務(wù)時(shí)，主線程需要等待多個(gè)組件加載完畢，之后再繼續(xù)執(zhí)行。

CountDownLatch典型用法：2、實(shí)現(xiàn)多個(gè)線程開(kāi)始執(zhí)行任務(wù)的最大并行性。注意是并行性，不是并發(fā)，強(qiáng)調(diào)的是多個(gè)線程在某一時(shí)刻同時(shí)開(kāi)始執(zhí)行。類似于賽跑，將多個(gè)線程放到起點(diǎn)，等待發(fā)令槍響，然后同時(shí)開(kāi)跑。做法是初始化一個(gè)共享的CountDownLatch(1)，將其計(jì)算器初始化為1，多個(gè)線程在開(kāi)始執(zhí)行任務(wù)前首先countdownlatch.await()，當(dāng)主線程調(diào)用countDown()時(shí)，計(jì)數(shù)器變?yōu)?，多個(gè)線程同時(shí)被喚醒。

舉個(gè)栗子：

package com.example.demo.CountDownLatchDemo;import java.util.concurrent.CountDownLatch;import java.util.concurrent.ExecutorService;import java.util.concurrent.Executors;/**
 * 主線程等待子線程執(zhí)行完成再執(zhí)行 */public class CountdownLatchTest {public static void main(String[] args) {
        ExecutorService service = Executors.newFixedThreadPool(3);final CountDownLatch latch = new CountDownLatch(3);for (int i = 0; i < 3; i++) {
            Runnable runnable = new Runnable() {
                @Overridepublic void run() {try {
                        System.out.println("子線程" + Thread.currentThread().getName() + "開(kāi)始執(zhí)行");
                        Thread.sleep((long) (Math.random() * 10000));
                        System.out.println("子線程"+Thread.currentThread().getName()+"執(zhí)行完成");
                        latch.countDown();//當(dāng)前線程調(diào)用此方法，則計(jì)數(shù)減一} catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            };
            service.execute(runnable);
        }try {
            System.out.println("主線程"+Thread.currentThread().getName()+"等待子線程執(zhí)行完成...");
            latch.await();//阻塞當(dāng)前線程，直到計(jì)數(shù)器的值為0System.out.println("主線程"+Thread.currentThread().getName()+"開(kāi)始執(zhí)行...");
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

到此，相信大家對(duì)“CountDownLatch有哪些用法”有了更深的了解，不妨來(lái)實(shí)際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進(jìn)入相關(guān)頻道進(jìn)行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！