快捷導(dǎo)航

Java中的Semaphore計(jì)數(shù)信號(hào)量詳細(xì)解析

更新時(shí)間：2023年11月20日 08:34:05 作者：夢(mèng)斷淚影

這篇文章主要介紹了Java中的Semaphore計(jì)數(shù)信號(hào)量詳細(xì)解析,Semaphore?是一個(gè)計(jì)數(shù)信號(hào)量,必須由獲取它的線程釋放,常用于限制可以訪問(wèn)某些資源的線程數(shù)量,例如通過(guò)?Semaphore?限流,需要的朋友可以參考下

1.介紹

Semaphore 是一個(gè)計(jì)數(shù)信號(hào)量，必須由獲取它的線程釋放。

常用于限制可以訪問(wèn)某些資源的線程數(shù)量，例如通過(guò) Semaphore 限流。

2.具體方法

acquire()
- 獲取一個(gè)令牌，在獲取到令牌、或者被其他線程調(diào)用中斷之前線程一直處于阻塞狀態(tài)。
acquire(int permits)
- 獲取一個(gè)令牌，在獲取到令牌、或者被其他線程調(diào)用中斷、或超時(shí)之前線程一直處于阻塞狀態(tài)。
acquireUninterruptibly()
- 獲取一個(gè)令牌，在獲取到令牌之前線程一直處于阻塞狀態(tài)（忽略中斷）。
tryAcquire()
- 嘗試獲得令牌，返回獲取令牌成功或失敗，不阻塞線程。
tryAcquire(long timeout, TimeUnit unit)
- 嘗試獲得令牌，在超時(shí)時(shí)間內(nèi)循環(huán)嘗試獲取，直到嘗試獲取成功或超時(shí)返回，不阻塞線程。
release()
- 釋放一個(gè)令牌，喚醒一個(gè)獲取令牌不成功的阻塞線程。
hasQueuedThreads()
- 等待隊(duì)列里是否還存在等待線程。
getQueueLength()
- 獲取等待隊(duì)列里阻塞的線程數(shù)。
drainPermits()
- 清空令牌把可用令牌數(shù)置為0，返回清空令牌的數(shù)量。
availablePermits()
- 返回可用的令牌數(shù)量。

3.實(shí)現(xiàn)場(chǎng)景

模擬停車場(chǎng)停車，進(jìn)來(lái)一輛，指示牌減一，出去一輛，指示牌加一，當(dāng)指示牌顯示為0時(shí)，禁止車輛進(jìn)入。

public class Test_Semaphore {
    //停車場(chǎng)同時(shí)容納的車輛10
    private static Semaphore semaphore=new Semaphore(10);
    public static void main(String[] args) {
        //模擬50輛車進(jìn)入停車場(chǎng)
        for(int i=0;i<50;i++){
            Thread thread=new Thread(new Runnable() {
                @Override
                public void run() {
                    try {
                        System.out.println("===="+Thread.currentThread().getName()+"來(lái)到停車場(chǎng)");
                        if(semaphore.availablePermits()==0){
                            System.out.println("車位不足，請(qǐng)耐心等待");
                        }
                        semaphore.acquire();//獲取令牌嘗試進(jìn)入停車場(chǎng)
                        System.out.println(Thread.currentThread().getName()+"成功進(jìn)入停車場(chǎng)");
                        Thread.sleep(new Random().nextInt(10000));//模擬車輛在停車場(chǎng)停留的時(shí)間
                        System.out.println(Thread.currentThread().getName()+"駛出停車場(chǎng)");
                        semaphore.release();//釋放令牌，騰出停車場(chǎng)車位
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
            },i+"號(hào)車");
            thread.start();
        }
    }
}

到此這篇關(guān)于Java中的Semaphore計(jì)數(shù)信號(hào)量詳細(xì)解析的文章就介紹到這了,更多相關(guān)Semaphore計(jì)數(shù)信號(hào)量?jī)?nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！