欧美bbbwbbbw肥妇,免费乱码人妻系列日韩,一级黄片

java?JUC信號量Semaphore原理及使用介紹

 更新時(shí)間:2022年11月30日 10:22:11   作者:JAVA旭陽  
這篇文章主要為大家介紹了java?JUC信號量Semaphore原理及使用介紹,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

前言

大家應(yīng)該都用過synchronized 關(guān)鍵字加鎖,用來保證某個時(shí)刻只允許一個線程運(yùn)行。

那么如果控制某個時(shí)刻允許指定數(shù)量的線程執(zhí)行,有什么好的辦法呢? 答案就是JUC提供的信號量Semaphore。

介紹和使用

  • Semaphore(信號量)可以用來限制能同時(shí)訪問共享資源的線程上限,它內(nèi)部維護(hù)了一個許可的變量,也就是線程許可的數(shù)量
  • Semaphore的許可數(shù)量如果小于0個,就會阻塞獲取,直到有線程釋放許可
  • Semaphore是一個非重入鎖

API介紹

  • 構(gòu)造方法
  • public Semaphore(int permits)permits 表示許可線程的數(shù)量
  • public Semaphore(int permits, boolean fair)fair 表示公平性,如果設(shè)為 true,表示是公平,那么等待最久的線程先執(zhí)行
  • 常用API
  • public void acquire():表示一個線程獲取1個許可,那么線程許可數(shù)量相應(yīng)減少一個
  • public void release():表示釋放1個許可,那么線程許可數(shù)量相應(yīng)會增加
  • 其他API
  • void acquire(int permits):表示一個線程獲取n個許可,這個數(shù)量由參數(shù)permits決定
  • void release(int permits):表示一個線程釋放n個許可,這個數(shù)量由參數(shù)permits決定
  • int availablePermits():返回當(dāng)前信號量線程許可數(shù)量
  • int getQueueLength(): 返回等待獲取許可的線程數(shù)的預(yù)估值

基本使用

public static void main(String[] args) {
        // 1. 創(chuàng)建 semaphore 對象
        Semaphore semaphore = new Semaphore(2);
        // 2. 10個線程同時(shí)運(yùn)行
        for (int i = 0; i < 8; i++) {
            new Thread(() -> {
                // 3. 獲取許可
                try {
                    semaphore.acquire();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                try {
                    log.debug("running...");
                    sleep(1);
                    log.debug("end...");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    // 4. 釋放許可
                    semaphore.release();
                }
            }).start();
        }
    }

運(yùn)行結(jié)果:

原理介紹

上面是Semaphore的類結(jié)構(gòu)圖,其中FairSyncNonfairSync是它的內(nèi)部類,他們共同繼承了AQS類,AQS的共享模式提供了Semaphore的加鎖、解鎖。

如果對AQS不了解的請移步深入淺出理解Java并發(fā)AQS的共享鎖模式

為了更好的搞懂原理,我們通過一個例子來幫助我們理解。

假設(shè)Semaphorepermits為 3,這時(shí) 5 個線程來獲取資源,其中Thread-1,Thread-2Thread-4CAS 競爭成功,permits 變?yōu)?0,而 Thread-0 Thread-3 競爭失敗。

獲取許可acquire()

  • acquire()主方法會調(diào)用 sync.acquireSharedInterruptibly(1)方法
  • acquireSharedInterruptibly()方法會先調(diào)用tryAcquireShared()方法返回許可的數(shù)量,如果小于0個,調(diào)用doAcquireSharedInterruptibly()方法進(jìn)入阻塞
// acquire() -> sync.acquireSharedInterruptibly(1),可中斷
public final void acquireSharedInterruptibly(int arg) {
    if (Thread.interrupted())
        throw new InterruptedException();
    // 嘗試獲取通行證,獲取成功返回 >= 0的值
    if (tryAcquireShared(arg) < 0)
        // 獲取許可證失敗,進(jìn)入阻塞
        doAcquireSharedInterruptibly(arg);
}
  • tryAcquireShared()方法在終會調(diào)用到Sync#nonfairTryAcquireShared()方法
  • nonfairTryAcquireShared()方法中會減去獲取的許可數(shù)量,返回剩余的許可數(shù)量
// tryAcquireShared() -> nonfairTryAcquireShared()
// 非公平,公平鎖會在循環(huán)內(nèi) hasQueuedPredecessors()方法判斷阻塞隊(duì)列是否有臨頭節(jié)點(diǎn)(第二個節(jié)點(diǎn))
final int nonfairTryAcquireShared(int acquires) {
    for (;;) {
        // 獲取 state ,state 這里【表示通行證】
        int available = getState();
        // 計(jì)算當(dāng)前線程獲取通行證完成之后,通行證還剩余數(shù)量
        int remaining = available - acquires;
        // 如果許可已經(jīng)用完, 返回負(fù)數(shù), 表示獲取失敗,
        if (remaining < 0 ||
            // 許可證足夠分配的,如果 cas 重試成功, 返回正數(shù), 表示獲取成功
            compareAndSetState(available, remaining))
            return remaining;
    }
}
  • 如果剩余的許可數(shù)量<0, 會調(diào)用doAcquireSharedInterruptibly()方法將當(dāng)前線程加入到阻塞隊(duì)列中阻塞
  • 方法中調(diào)用parkAndCheckInterrupt()阻塞當(dāng)前線程
private void doAcquireSharedInterruptibly(int arg) {
    // 將調(diào)用 Semaphore.aquire 方法的線程,包裝成 node 加入到 AQS 的阻塞隊(duì)列中
    final Node node = addWaiter(Node.SHARED);
    // 獲取標(biāo)記
    boolean failed = true;
    try {
        for (;;) {
            final Node p = node.predecessor();
            // 前驅(qū)節(jié)點(diǎn)是頭節(jié)點(diǎn)可以再次獲取許可
            if (p == head) {
                // 再次嘗試獲取許可,【返回剩余的許可證數(shù)量】
                int r = tryAcquireShared(arg);
                if (r >= 0) {
                    // 成功后本線程出隊(duì)(AQS), 所在 Node設(shè)置為 head
                    // r 表示【可用資源數(shù)】, 為 0 則不會繼續(xù)傳播
                    setHeadAndPropagate(node, r); 
                    p.next = null; // help GC
                    failed = false;
                    return;
                }
            }
            // 不成功, 設(shè)置上一個節(jié)點(diǎn) waitStatus = Node.SIGNAL, 下輪進(jìn)入 park 阻塞
            if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt())
                throw new InterruptedException();
        }
    } finally {
        // 被打斷后進(jìn)入該邏輯
        if (failed)
            cancelAcquire(node);
    }
}

最終的AQS狀態(tài)如下圖所示:

  • Thread-1、Thread-2、Thread-4正常運(yùn)行
  • AQS的state也就是等于0
  • Thread-0、Thread-3再阻塞隊(duì)列中

釋放許可release()

現(xiàn)在Thread-4運(yùn)行完畢,要釋放許可,Thread-0、Thread-3又是如何恢復(fù)執(zhí)行的呢?

  • 調(diào)用release()方法釋放許可,最終調(diào)用 Sync#releaseShared()方法
  • 如果方法tryReleaseShared(arg)嘗試釋放許可成功,那么調(diào)用doReleaseShared();進(jìn)行喚醒
// release() -> releaseShared()
public final boolean releaseShared(int arg) {
    // 嘗試釋放鎖
    if (tryReleaseShared(arg)) {
        doReleaseShared();
        return true;
    }    
    return false;
}
  • tryReleaseShared()方法主要是嘗試釋放許可
  • 獲取當(dāng)前許可數(shù)量 + 釋放的數(shù)量,然后通過cas設(shè)置回去
protected final boolean tryReleaseShared(int releases) {    
    for (;;) {
        // 獲取當(dāng)前鎖資源的可用許可證數(shù)量
        int current = getState();
        int next = current + releases;
        // 索引越界判斷
        if (next < current)            
            throw new Error("Maximum permit count exceeded");        
        // 釋放鎖
        if (compareAndSetState(current, next))            
            return true;    
    }
}
  • 調(diào)用doReleaseShared()方法喚醒隊(duì)列中的線程
  • 其中unparkSuccessor()方法是喚醒的核心操作
// 喚醒
private void doReleaseShared() {
    // 如果 head.waitStatus == Node.SIGNAL ==> 0 成功, 下一個節(jié)點(diǎn) unpark	
    // 如果 head.waitStatus == 0 ==> Node.PROPAGATE    
    for (;;) {
        Node h = head;
        if (h != null && h != tail) {
            int ws = h.waitStatus;
            if (ws == Node.SIGNAL) {
                // 防止 unparkSuccessor 被多次執(zhí)行
                if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0))
                    continue;
                // 喚醒后繼節(jié)點(diǎn)
                unparkSuccessor(h);
            }
            // 如果已經(jīng)是 0 了,改為 -3,用來解決傳播性
            else if (ws == 0 && !compareAndSetWaitStatus(h, 0, Node.PROPAGATE))
                continue;
        }
        if (h == head)
            break;
    }
}

最終AQS狀態(tài)如下圖所示:

  • 許可state變回1
  • 然后Thread-0開始競爭,如果競爭成功,如下圖所示:

  • 由于Thread-0競爭成功,再次獲取到許可,許可數(shù)量減1,最終又變回0
  • 然后等待隊(duì)列中剩余Thread-3

總結(jié)

Semaphore信號量類基于AQS的共享鎖實(shí)現(xiàn),有公平鎖和非公平鎖兩個版本,它用來限制能同時(shí)訪問共享資源的線程上限,典型的應(yīng)用場景是可以用來保護(hù)有限的公共資源,比如數(shù)據(jù)庫連接等。

以上就是java JUC信號量Semaphore原理及使用介紹的詳細(xì)內(nèi)容,更多關(guān)于java JUC信號量Semaphore的資料請關(guān)注腳本之家其它相關(guān)文章!

相關(guān)文章

  • idea快捷鍵生成getter和setter,有構(gòu)造參數(shù),無構(gòu)造參數(shù),重寫toString方式

    idea快捷鍵生成getter和setter,有構(gòu)造參數(shù),無構(gòu)造參數(shù),重寫toString方式

    這篇文章主要介紹了java之idea快捷鍵生成getter和setter,有構(gòu)造參數(shù),無構(gòu)造參數(shù),重寫toString方式,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2023-11-11
  • Java流處理stream使用詳解

    Java流處理stream使用詳解

    Java8的另一大亮點(diǎn)Stream,它與java.io包里的InputStream和OutputStream是完全不同的概念,下面這篇文章主要給大家介紹了關(guān)于Java8中Stream詳細(xì)使用方法的相關(guān)資料,需要的朋友可以參考下
    2022-10-10
  • java類加載器和類反射使用示例

    java類加載器和類反射使用示例

    這篇文章主要介紹了java類加載器和類反射使用示例,需要的朋友可以參考下
    2014-03-03
  • SpringBoot項(xiàng)目配置postgresql數(shù)據(jù)庫完整步驟(配置多數(shù)據(jù)源)

    SpringBoot項(xiàng)目配置postgresql數(shù)據(jù)庫完整步驟(配置多數(shù)據(jù)源)

    PostgreSQL是一種特性非常齊全的自由軟件的對象-關(guān)系型數(shù)據(jù)庫管理系統(tǒng)(ORDBMS),下面這篇文章主要給大家介紹了關(guān)于SpringBoot項(xiàng)目配置postgresql數(shù)據(jù)庫(配置多數(shù)據(jù)源)的相關(guān)資料,需要的朋友可以參考下
    2023-05-05
  • Spring Boot 2.x中Actuator的一些知識點(diǎn)

    Spring Boot 2.x中Actuator的一些知識點(diǎn)

    這篇文章主要給大家介紹了關(guān)于Spring Boot 2.x中Actuator的一些知識點(diǎn),文中通過示例代碼介紹的非常詳細(xì),對大家學(xué)習(xí)或者使用Spring Boot 2.x具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面來一起學(xué)習(xí)學(xué)習(xí)吧
    2019-09-09
  • Java的異常類型總結(jié)

    Java的異常類型總結(jié)

    在本篇文章里小編給大家分享了關(guān)于Java的異常類型的相關(guān)知識點(diǎn)內(nèi)容,有需要的朋友們跟著學(xué)習(xí)下。
    2019-01-01
  • SpringBoot多環(huán)境日志配置方式

    SpringBoot多環(huán)境日志配置方式

    SpringBoot?默認(rèn)使用LogBack日志系統(tǒng),默認(rèn)情況下,SpringBoot項(xiàng)目的日志只會在控制臺輸入,本文給大家介紹SpringBoot多環(huán)境日志配置方式,需要的朋友可以參考下
    2024-08-08
  • JAVA JDK8 List獲取屬性列表

    JAVA JDK8 List獲取屬性列表

    今天小編就為大家分享一篇關(guān)于JAVA JDK8 List獲取屬性列表,小編覺得內(nèi)容挺不錯的,現(xiàn)在分享給大家,具有很好的參考價(jià)值,需要的朋友一起跟隨小編來看看吧
    2018-12-12
  • Spring容器注冊組件實(shí)現(xiàn)過程解析

    Spring容器注冊組件實(shí)現(xiàn)過程解析

    這篇文章主要介紹了Spring容器注冊組件實(shí)現(xiàn)過程解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
    2020-03-03
  • mybatisPlus更新策略導(dǎo)致更新失敗問題

    mybatisPlus更新策略導(dǎo)致更新失敗問題

    這篇文章主要介紹了mybatisPlus更新策略導(dǎo)致更新失敗問題,具有很好的參考價(jià)值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2024-08-08

最新評論