簡單介紹

我們以飯店為例，假設(shè)飯店只有三個(gè)座位，一開始三個(gè)座位都是空的。這時(shí)如果同時(shí)來了三個(gè)客人，服務(wù)員人允許他們進(jìn)去用餐，然后對外說暫無座位。后來的客人必須在門口等待，直到有客人離開。這時(shí)，如果有一個(gè)客人離開，服務(wù)員告訴客人，可以進(jìn)來用餐，如果又有客人離開，則又可以進(jìn)來客人用餐，如此往復(fù)。

在這個(gè)飯店中，座位是公共資源，每個(gè)人好比一個(gè)線程，服務(wù)員起的就是信號量的作用。信號量是一個(gè)非負(fù)整數(shù)，表示了當(dāng)前公共資源的可用數(shù)目(在上面的例子中可以用空閑的座位類比信號量)，當(dāng)一個(gè)線程要使用公共資源時(shí)(在上面的例子中可以用客人比線程)，首先要查看信號量，如果信號量的值大于1，則將其減1，然后去占有公共資源。如果信號量的值為0，則線程會將自己阻塞，直到有其它線程釋放公共資源。

1、簡單介紹Semaphore

a、可用來控制同時(shí)訪問特定資源的線程數(shù)量，以此來達(dá)到協(xié)調(diào)線程工作。

b、維護(hù)了一個(gè)虛擬的資源池，如果許可為0則線程阻塞等待，直到許可大于0時(shí)又可以有機(jī)會獲取許可了。

c、 內(nèi)部也有公平鎖、非公平鎖來訪問資源的靜態(tài)內(nèi)部類。

2、Semaphore方法

a、public Semaphore(int permits);// 創(chuàng)建一個(gè)給定許可數(shù)量的信號量對象，且默認(rèn)以非公平鎖方式獲取資源

b、public Semaphore(int permits, boolean fair);//創(chuàng)建一個(gè)給定許可數(shù)量的信號量對象，且是否公平方式由傳入的fair布爾參數(shù)值決定

c、public void acquire() ;//從此信號量獲取一個(gè)許可，當(dāng)許可數(shù)量小于零時(shí)，則阻塞等待

d、public void acquire(int permits) ;//從此信號量獲取permits個(gè)許可，當(dāng)許可數(shù)量小于零時(shí)，則阻塞等待，但是當(dāng)阻塞等待的線程被喚醒后發(fā)現(xiàn)被中斷過的話則會拋InterruptedException異常

e、public void acquireUninterruptibly(int permits) ;從此信號量獲取permits個(gè)許可，當(dāng)許可數(shù)量小于零時(shí)，則阻塞等待，但是當(dāng)阻塞等待的線程被喚醒后發(fā)現(xiàn)被中斷過的話則不會拋InterruptedException異常

f、public void release();//釋放一個(gè)許可

g、public void release(int permits);釋放permits個(gè)許可

以上只是列出主要方法名，方法詳細(xì)解釋，Semaphore類上面都有注釋。就不一一累出來了。

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

/**

* @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;

}

@Override

public 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();//同步隊(duì)列線程

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();

}

}

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

總結(jié)

以上是生活随笔為你收集整理的java semaphore 等待_Java并发编程系列之Semaphore详解的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。