簡單介紹

我們以飯店為例，假設飯店只有三個座位，一開始三個座位都是空的。這時如果同時來了三個客人，服務員人允許其中他們進去用餐，然后對外說暫無座位。后來的客人必須在門口等待，直到有客人離開。這時，如果有一個客人離開，服務員告訴客人，可以進來用餐，如果又客人離開，則又可以進來客人用餐，如此往復。
在這個飯店中，座位是公共資源，每個人好比一個線程，服務員起的就是信號量的作用。信號量是一個非負整數，表示了當前公共資源的可用數目（在上面的例子中可以用空閑的座位類比信號量），當一個線程要使用公共資源時（在上面的例子中可以用客人比線程），首先要查看信號量，如果信號量的值大于1，則將其減1，然后去占有公共資源。如果信號量的值為0，則線程會將自己阻塞，直到有其它線程釋放公共資源。

1、簡單介紹Semaphore

a、可用來控制同時訪問特定資源的線程數量，以此來達到協調線程工作。
b、維護了一個虛擬的資源池，如果許可為0則線程阻塞等待，直到許可大于0時又可以有機會獲取許可了。
c、 內部也有公平鎖、非公平鎖來訪問資源的靜態內部類。

2、Semaphore方法

a、public Semaphore(int permits);// 創建一個給定許可數量的信號量對象，且默認以非公平鎖方式獲取資源
b、public Semaphore(int permits, boolean fair);//創建一個給定許可數量的信號量對象，且是否公平方式由傳入的fair布爾參數值決定
c、public void acquire() ;//從此信號量獲取一個許可，當許可數量小于零時，則阻塞等待
d、public void acquire(int permits) ;//從此信號量獲取permits個許可，當許可數量小于零時，則阻塞等待，但是當阻塞等待的線程被喚醒后發現被中斷過的話則會拋InterruptedException異常
e、public void acquireUninterruptibly(int permits) ;從此信號量獲取permits個許可，當許可數量小于零時，則阻塞等待，但是當阻塞等待的線程被喚醒后發現被中斷過的話則不會拋InterruptedException異常
f、public void release();//釋放一個許可
g、public void release(int permits);釋放permits個許可
以上只是列出主要方法名，方法詳細解釋，Semaphore類上面都有注釋。就不一一累出來了。

舉一個簡單例子，幫助我們加深印象

/*** @author shuliangzhao* @Title: SemaPhoreTest* @ProjectName design-parent* @Description: TODO* @date 2019/6/5 22:50*/ public class SemaPhoreTest {private Semaphore semaphore = new Semaphore(3);class TaskThread implements Runnable{private int id;public TaskThread(int id) {this.id = id;}@Overridepublic void run() {try {semaphore.acquire();System.out.println("Thread " + id + " is working");Thread.sleep(2000);semaphore.release();System.out.println("Thread " + id + " is over");} catch (InterruptedException e) {e.printStackTrace();}}}public static void main(String[] args) {SemaPhoreTest semaPhoreTest = new SemaPhoreTest();/*for (int i = 0;i<6;i++) {Thread thread = new Thread(semaPhoreTest.new TaskThread(i));thread.start();}*/ExecutorService executorService = Executors.newCachedThreadPool();//同步隊列線程executorService.submit(semaPhoreTest.new TaskThread(1));executorService.submit(semaPhoreTest.new TaskThread(2));executorService.submit(semaPhoreTest.new TaskThread(3));executorService.submit(semaPhoreTest.new TaskThread(4));executorService.submit(semaPhoreTest.new TaskThread(5));executorService.submit(semaPhoreTest.new TaskThread(6));executorService.submit(semaPhoreTest.new TaskThread(7));executorService.shutdown();} }

運行結果

?

總結

以上是生活随笔為你收集整理的Java并发编程系列之Semaphore详解的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。