小編這次要給大家分享的是Java基于Semaphore怎么構建阻塞對象池，文章內容豐富，感興趣的小伙伴可以來了解一下，希望大家閱讀完這篇文章之后能夠有所收獲。
java中使用Semaphore構建阻塞對象池
Semaphore是java 5中引入的概念，叫做計數信號量。主要用來控制同時訪問某個特定資源的訪問數量或者執行某個操作的數量。
Semaphore中定義了一組虛擬的permits，通過獲取和釋放這些permits，Semaphore可以控制資源的個數。
Semaphore的這個特性可以用來構造資源池，比如數據庫連接池等。
Semaphore有兩個構造函數：
public Semaphore(int permits) {
sync = new NonfairSync(permits);
}
public Semaphore(int permits, boolean fair) {
sync = fair ? new FairSync(permits) : new NonfairSync(permits);
}permits定義了許可資源的個數，而fair則表示是否支持FIFO的順序。
兩個比較常用的方法就是acquire和release了。
public void acquire() throws InterruptedException {
sync.acquireSharedInterruptibly(1);
}
public void release() {
sync.releaseShared(1);
}其中acquire用來獲取資源，release用來釋放資源。
有了這兩個特性， 我們看一下怎么使用Semaphore來定義一個一個有界容器。
我們可以將Semaphore初始化為容器池大小，并且在容器池獲取資源時調用acquire，將資源返回給容器池之后再調用release。
我們看下面的一個實現：
public class SemaphoreUsage<T> {
private final Set<T> set;
private final Semaphore sem;
public SemaphoreUsage(int bound){
this.set = Collections.synchronizedSet(new HashSet<T>());
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怎么構建阻塞對象池的文章，如果覺得文章內容寫得不錯的話，可以把它分享出去給更多人看到。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
