快捷導(dǎo)航

Java中的Semaphore信號量簡單使用代碼實例

更新時間：2023年12月18日 10:33:06 作者：暴躁的程序猿啊

這篇文章主要介紹了Java中的Semaphore信號量簡單使用代碼實例,Semaphore是用來保護(hù)一個或者多個共享資源的訪問,Semaphore內(nèi)部維護(hù)了一個計數(shù)器,其值為可以訪問的共享資源的個數(shù),一個線程要訪問共享資源,需要的朋友可以參考下

Semaphore信號量

Semaphore是用來保護(hù)一個或者多個共享資源的訪問，Semaphore內(nèi)部維護(hù)了一個計數(shù)器，其值為可以訪問的共享資源的個數(shù)。

一個線程要訪問共享資源，先獲得信號量，如果信號量的計數(shù)器值大于1，意味著有共享資源可以訪問，則使其計數(shù)器值減去1，再訪問共享資源。

如果計數(shù)器值為0，線程進(jìn)入休眠。當(dāng)某個線程使用完共享資源后，釋放信號量，并將信號量內(nèi)部的計數(shù)器加1，之前進(jìn)入休眠的線程將被喚醒并再次試圖獲得信號量。例如：停車場的車位，有空閑車位才可以停，沒有空閑車位只能等待。主要使用方法：

acquire（） 從信號量獲取一個許可，在提供一個許可之前一直將線程阻塞否則線程被中斷

release（） 釋放一個許可，將其返回給信號量

例子：停車場有五個停車位有十輛車要停

public class SemaphoreDemo {
    public static void main(String[] args) {
        //參數(shù) 許可數(shù)量  例有五個空停車位
        Semaphore semaphore = new Semaphore(5);
        //模擬10輛汽車  要停車  只能有五輛汽車同時停  其他車只能等待
        for (int i = 0; i < 10; i++) {
            new Thread(() -> {
                try {
                    //acquire()得到  成功拿到車位停車
                    semaphore.acquire();
                    System.out.println(Thread.currentThread().getName() + "搶到車位");
                    //停兩秒鐘的車
                    TimeUnit.SECONDS.sleep(2);
                    //離開車位
                    System.out.println(Thread.currentThread().getName() + "離開車位");
                } catch (InterruptedException e) {
                    e.printStackTrace();
                } finally {
                    //release()釋放
                    semaphore.release();
                }
            }).start();
        }
    }
}

在這里插入圖片描述