Semaphore介紹

Semaphore，限制對(duì)共享資源訪問(wèn)的最大線程數(shù)量，要訪問(wèn)共享資源，需要先申請(qǐng)?jiān)S可，申請(qǐng)到許可才能訪問(wèn)。訪問(wèn)結(jié)果了，釋放許可。

成都創(chuàng)新互聯(lián)是一家專業(yè)提供巴南企業(yè)網(wǎng)站建設(shè),專注與網(wǎng)站設(shè)計(jì)、成都網(wǎng)站建設(shè)、H5場(chǎng)景定制、小程序制作等業(yè)務(wù)。10年已為巴南眾多企業(yè)、政府機(jī)構(gòu)等服務(wù)。創(chuàng)新互聯(lián)專業(yè)網(wǎng)絡(luò)公司優(yōu)惠進(jìn)行中。

案例：

3個(gè)線程：Thread-1、Thread-2、Thread-3。一個(gè)許可數(shù)為2的公平策略的Semaphore。

線程的調(diào)用順序如下：
Thread-1 申請(qǐng)一個(gè)許可，等待幾秒鐘，繼續(xù)執(zhí)行
Thread-2 申請(qǐng)2個(gè)許可，許可不足，阻塞
Thread-3 申請(qǐng)一個(gè)許可，等待幾秒鐘，繼續(xù)執(zhí)行
Thread-1,Thread-3,釋放許可之后，Thread-2可以申請(qǐng)?jiān)S可，成功執(zhí)行。

代碼：

Thread-1/3

import java.util.concurrent.Semaphore;

public class Task1 implements Runnable{

    private Semaphore semaphore;

    public Task1(Semaphore semaphore) {
        this.semaphore = semaphore;
    }

    @Override
    public void run() {

        try {
            semaphore.acquire();
            System.out.println(Thread.currentThread().getName() + "獲取到許可....");
            Thread.sleep(3000);
            System.out.println(Thread.currentThread().getName() + "執(zhí)行....");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            System.out.println(Thread.currentThread().getName() + "釋放許可....");
            semaphore.release();
        }
    }
}

Thread-2

import java.util.concurrent.Semaphore;

public class Task2 implements Runnable{

    private Semaphore semaphore;

    public Task2(Semaphore semaphore) {
        this.semaphore = semaphore;
    }

    @Override
    public void run() {

        try {
            System.out.println(Thread.currentThread().getName() + "申請(qǐng)?jiān)S可....");
            semaphore.acquire(2);
            System.out.println(Thread.currentThread().getName() + "獲取到許可....");
            Thread.sleep(3000);
            System.out.println(Thread.currentThread().getName() + "執(zhí)行....");
        } catch (InterruptedException e) {
            e.printStackTrace();
        } finally {
            System.out.println(Thread.currentThread().getName() + "釋放許可....");
            semaphore.release(2);
        }
    }
}

啟動(dòng)文件

import java.text.ParseException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Semaphore;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class Main {

    public static void main(String[] args) throws ParseException, InterruptedException {
        Semaphore semaphore = new Semaphore(2, true);

        ReentrantLock lock = new ReentrantLock(true);
        Condition condition = lock.newCondition();
        Thread t1 = new Thread(new Task1(semaphore),"Thread-1");
        t1.start();
        Thread.sleep(2000);
        Thread t2 = new Thread(new Task2(semaphore),"Thread-2");
        Thread t3 = new Thread(new Task1(semaphore),"Thread-3");
        t2.start();
        t3.start();
    }
}

結(jié)果：

源碼分析

創(chuàng)建公平的Semaphore，就是直接修改AQS的同步狀態(tài)state

Thread-1,申請(qǐng)?jiān)S可，執(zhí)行AQS的acquireSharedInterruptibly

Semaphore是如何實(shí)現(xiàn)tryAcquireShared方法的

此時(shí)，Thread-1申請(qǐng)一個(gè)，是足夠的，返回成功，然后持有許可，此時(shí)state=1。

Thread-2申請(qǐng)2個(gè)許可，但是state=1,不夠的。

Thread-2會(huì)申請(qǐng)失敗，進(jìn)入doAcquireSharedInterruptibly

doAcquireSharedInterruptibly方法之前的文章也介紹過(guò)了，這里不再詳細(xì)介紹，最終Thread-2被包裝成節(jié)點(diǎn)放【等待隊(duì)列】，同時(shí)需要設(shè)置【等待隊(duì)列】頭結(jié)點(diǎn)為SIGNAL狀態(tài)，然后Thread-2阻塞了。

Thread-3申請(qǐng)一個(gè)許可，是成功的，然后持有許可，此時(shí)state=0.

Thread-1，釋放了許可，則state=1;

然后執(zhí)行doReleaseShared，設(shè)置頭節(jié)點(diǎn)狀態(tài)為0，準(zhǔn)備喚醒后繼節(jié)點(diǎn)，也就是Thread-2.

此時(shí)，可能Thread-3還沒(méi)有釋放許可，state=1,那么Thread-2又會(huì)被阻塞。

Thread-3,釋放許可，state=2,繼續(xù)喚醒Thread-2.

Thread-2,獲取許可成功，state=0,繼續(xù)執(zhí)行。

Thread-2,釋放許可，state=2,程序執(zhí)行完成。

網(wǎng)頁(yè)標(biāo)題：多線程（十三、AQS原理-Semaphore信號(hào)量）
當(dāng)前路徑：http://aaarwkj.com/article32/peeopc.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供服務(wù)器托管、微信公眾號(hào)、App開(kāi)發(fā)、用戶體驗(yàn)、響應(yīng)式網(wǎng)站、網(wǎng)站設(shè)計(jì)公司

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請(qǐng)盡快告知，我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如需處理請(qǐng)聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時(shí)需注明來(lái)源： 創(chuàng)新互聯(lián)