快捷導(dǎo)航

Java中的共享鎖CountDownLatch及源碼解析

更新時(shí)間：2023年11月16日 09:28:40 作者：立小研先森

這篇文章主要介紹了Java中的共享鎖CountDownLatch及源碼解析,CountDownLatch是一種同步輔助工具,允許一個(gè)或多個(gè)線程等待,直到在其它線程中執(zhí)行的一組操作完成；CountDownLatch使用指定的計(jì)數(shù)初始化,需要的朋友可以參考下

前言

CountDownLatch是一種同步輔助工具，允許一個(gè)或多個(gè)線程等待，直到在其它線程中執(zhí)行的一組操作完成；CountDownLatch使用指定的計(jì)數(shù)初始化。

wait方法會(huì)阻塞，直到當(dāng)前計(jì)數(shù)由于countDown方法的調(diào)用而達(dá)到零，之后所有的等待線程都會(huì)被釋放，任何后續(xù)的wait調(diào)用都會(huì)立即返回。這是一種一次性現(xiàn)象，計(jì)數(shù)無法重置。如果需要重置計(jì)數(shù)的版本，可以參考CyclicBarrier。

一、CountDownLatch的使用方法

public class Test {
    public static void main(String[] args) throws InterruptedException {
        CountDownLatch latch = new CountDownLatch(3);
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("線程一執(zhí)行完成");
                latch.countDown();
            }
        }).start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                try {
                    Thread.sleep(1000);
                } catch (InterruptedException e) {
                    throw new RuntimeException(e);
                }
                System.out.println("線程二執(zhí)行完成");
                latch.countDown();
            }
        }).start();
        new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("線程三執(zhí)行完成");
                latch.countDown();
            }
        }).start();
        System.out.println("主線程等待");
        latch.await();
        System.out.println("主線程開始執(zhí)行");
    }
}

執(zhí)行結(jié)果如下：

線程三執(zhí)行完成
主線程等待
線程二執(zhí)行完成
線程一執(zhí)行完成
主線程開始執(zhí)行

上面的示例是一個(gè)主線程等待其它三個(gè) 線程執(zhí)行，執(zhí)行完成后調(diào)用countDown方法，計(jì)數(shù)減一，直到所有的線程執(zhí)行完成，計(jì)數(shù)歸0，然后await方法放回，主線程繼續(xù)執(zhí)行。

二、CountDownLatch源碼解析

  public void countDown() {
        sync.releaseShared(1);
    }

countDown方法會(huì)遞減鎖的計(jì)數(shù)器，如果計(jì)數(shù)為0，則釋放所有等待的線程。如果當(dāng)前計(jì)數(shù)大于0，則遞減。如果新計(jì)數(shù)為0，則出于線程調(diào)度的目的重新啟用所有等待線程。如果當(dāng)前計(jì)數(shù)等于0，那么什么也不發(fā)生。

 public void await() throws InterruptedException {
        sync.acquireSharedInterruptibly(1);
    }

await方法會(huì)使當(dāng)前線程等待，直到鎖的計(jì)數(shù)器為0，除非線程被中斷。如果當(dāng)前計(jì)數(shù)為0，則此方法立即返回。如果當(dāng)前計(jì)數(shù)大于0，則出于線程調(diào)度目的，當(dāng)前線程將被禁用，并處于休眠狀態(tài)，直到發(fā)生一下兩種情況之一：

1.由于調(diào)用了countDown方法，計(jì)數(shù)達(dá)到了0；

2.其它線程終端當(dāng)前線程；

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

您可能感興趣的文章: