小編這次要給大家分享的是Java基于Semaphore怎么構建阻塞對象池，文章內容豐富，感興趣的小伙伴可以來了解一下，希望大家閱讀完這篇文章之后能夠有所收獲。
成都創(chuàng)新互聯(lián)是一家專注于成都網(wǎng)站設計、網(wǎng)站制作與策劃設計,錫林浩特網(wǎng)站建設哪家好?成都創(chuàng)新互聯(lián)做網(wǎng)站,專注于網(wǎng)站建設十余年,網(wǎng)設計領域的專業(yè)建站公司;建站業(yè)務涵蓋:錫林浩特等地區(qū)。錫林浩特做網(wǎng)站價格咨詢:18980820575
java中使用Semaphore構建阻塞對象池
Semaphore是java 5中引入的概念，叫做計數(shù)信號量。主要用來控制同時訪問某個特定資源的訪問數(shù)量或者執(zhí)行某個操作的數(shù)量。
Semaphore中定義了一組虛擬的permits，通過獲取和釋放這些permits，Semaphore可以控制資源的個數(shù)。
Semaphore的這個特性可以用來構造資源池，比如數(shù)據(jù)庫連接池等。
Semaphore有兩個構造函數(shù)：
重慶分公司
重慶分公司
public Semaphore(int permits) {
sync = new NonfairSync(permits);
}
public Semaphore(int permits, boolean fair) {
sync = fair ? new FairSync(permits) : new NonfairSync(permits);
}permits定義了許可資源的個數(shù)，而fair則表示是否支持FIFO的順序。
兩個比較常用的方法就是acquire和release了。
public void acquire() throws InterruptedException {
sync.acquireSharedInterruptibly(1);
}
public void release() {
sync.releaseShared(1);
}其中acquire用來獲取資源，release用來釋放資源。
有了這兩個特性， 我們看一下怎么使用Semaphore來定義一個一個有界容器。
我們可以將Semaphore初始化為容器池大小，并且在容器池獲取資源時調用acquire，將資源返回給容器池之后再調用release。
我們看下面的一個實現(xiàn)：
public class SemaphoreUsage{ private final Set set; private final Semaphore sem; public SemaphoreUsage(int bound){ this.set = Collections.synchronizedSet(new HashSet ()); sem= new Semaphore(bound); } public boolean add (T o) throws InterruptedException{ sem.acquire(); boolean wasAdded = false; try{ wasAdded=set.add(o); return wasAdded; }finally { if(!wasAdded){ sem.release(); } } } public boolean remove(Object o){ boolean wasRemoved = set.remove(o); if(wasRemoved){ sem.release(); } return wasRemoved; } }
上面的例子我們定義了一個有界的synchronizedSet。 要注意一點是在add方法中，只有add成功之后才會調用release方法。
看完這篇關于Java基于Semaphore怎么構建阻塞對象池的文章，如果覺得文章內容寫得不錯的話，可以把它分享出去給更多人看到。
