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方法。

本文的例子請參考https://github.com/ddean2009/learn-java-concurrency/tree/master/Semaphore

更多精彩內容且看：

• 區塊鏈從入門到放棄系列教程-涵蓋密碼學,超級賬本,以太坊,Libra,比特幣等持續更新
• Spring Boot 2.X系列教程:七天從無到有掌握Spring Boot-持續更新
• Spring 5.X系列教程:滿足你對Spring5的一切想象-持續更新
• java程序員從小工到專家成神之路（2020版）-持續更新中,附詳細文章教程

更多內容請訪問 flydean的博客

總結

以上是生活随笔為你收集整理的java中使用Semaphore构建阻塞对象池的全部內容，希望文章能夠幫你解決所遇到的問題。

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