溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

Java基于Semaphore怎么構(gòu)建阻塞對(duì)象池

發(fā)布時(shí)間：2020-07-30 14:56:10 來源：億速云 閱讀：144 作者：小豬 欄目：編程語言

小編這次要給大家分享的是Java基于Semaphore怎么構(gòu)建阻塞對(duì)象池，文章內(nèi)容豐富，感興趣的小伙伴可以來了解一下，希望大家閱讀完這篇文章之后能夠有所收獲。

java中使用Semaphore構(gòu)建阻塞對(duì)象池

Semaphore是java 5中引入的概念，叫做計(jì)數(shù)信號(hào)量。主要用來控制同時(shí)訪問某個(gè)特定資源的訪問數(shù)量或者執(zhí)行某個(gè)操作的數(shù)量。

Semaphore中定義了一組虛擬的permits，通過獲取和釋放這些permits，Semaphore可以控制資源的個(gè)數(shù)。

Semaphore的這個(gè)特性可以用來構(gòu)造資源池，比如數(shù)據(jù)庫連接池等。

Semaphore有兩個(gè)構(gòu)造函數(shù)：

  public Semaphore(int permits) {
    sync = new NonfairSync(permits);
  }
  public Semaphore(int permits, boolean fair) {
    sync = fair ? new FairSync(permits) : new NonfairSync(permits);
  }

permits定義了許可資源的個(gè)數(shù)，而fair則表示是否支持FIFO的順序。

兩個(gè)比較常用的方法就是acquire和release了。

  public void acquire() throws InterruptedException {
    sync.acquireSharedInterruptibly(1);
  }
  public void release() {
    sync.releaseShared(1);
  }

其中acquire用來獲取資源，release用來釋放資源。

有了這兩個(gè)特性， 我們看一下怎么使用Semaphore來定義一個(gè)一個(gè)有界容器。

我們可以將Semaphore初始化為容器池大小，并且在容器池獲取資源時(shí)調(diào)用acquire，將資源返回給容器池之后再調(diào)用release。

我們看下面的一個(gè)實(shí)現(xiàn)：

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;
  }
}

上面的例子我們定義了一個(gè)有界的synchronizedSet。 要注意一點(diǎn)是在add方法中，只有add成功之后才會(huì)調(diào)用release方法。

看完這篇關(guān)于Java基于Semaphore怎么構(gòu)建阻塞對(duì)象池的文章，如果覺得文章內(nèi)容寫得不錯(cuò)的話，可以把它分享出去給更多人看到。

向AI問一下細(xì)節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng)，如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱：is@yisu.com進(jìn)行舉報(bào)，并提供相關(guān)證據(jù)，一經(jīng)查實(shí)，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手