快捷導(dǎo)航

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

更新時(shí)間：2020年04月24日 15:16:41 作者：flydean程序那些事

這篇文章主要介紹了Java基于Semaphore構(gòu)建阻塞對(duì)象池,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下

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

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

以上就是本文的全部?jī)?nèi)容，希望對(duì)大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。

您可能感興趣的文章:

相關(guān)文章

CountDownLatch同步工具類使用詳解
這篇文章主要為大家詳細(xì)介紹了CountDownLatch的使用說明，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2018-04-04
8種常見的接口請(qǐng)求重試方法總結(jié)
在跨境業(yè)務(wù)中,可能第三方的服務(wù)器分布在世界的各個(gè)角落,所以請(qǐng)求三方接口的時(shí)候,難免會(huì)遇到一些網(wǎng)絡(luò)問題,這時(shí)候需要加入重試機(jī)制了,下面小編就給大家分享幾個(gè)接口重試的寫法吧
2023-11-11
Spring interceptor攔截器配置及用法解析
這篇文章主要介紹了Spring interceptor攔截器配置及用法解析,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下
2020-10-10
Java基礎(chǔ)篇之反射機(jī)制示例詳解
反射是Java可以提供的一個(gè)靈活又強(qiáng)大的功能,使用Java反射,您可以知道這個(gè)類在運(yùn)行時(shí)具有什么屬性和方法,也可以修改屬性,調(diào)用方法,創(chuàng)建類的實(shí)例,這篇文章主要給大家介紹了關(guān)于Java基礎(chǔ)篇之反射機(jī)制的相關(guān)資料,需要的朋友可以參考下
2021-11-11
Java中的函數(shù)式編程
這篇文章介紹Java中的函數(shù)式編程，函數(shù)式編程是一種編程范式，其中程序是通過應(yīng)用和組合函數(shù)來構(gòu)造的。它是一種聲明式編程范式，其中函數(shù)定義是表達(dá)式樹，每個(gè)表達(dá)式樹返回一個(gè)值，而不是一系列改變程序狀態(tài)的命令語句，具體情況請(qǐng)看下文，希望對(duì)你有所幫助
2021-10-10
java中有關(guān)構(gòu)造方法中的輸出
這篇文章主要介紹了java中有關(guān)構(gòu)造方法中的輸出，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2022-10-10
詳解IntelliJ IDEA 中如何配置多個(gè)jdk版本即(1.7和1.8兩個(gè)jdk都可用)
這篇文章主要介紹了詳解IntelliJ IDEA 中如何配置多個(gè)jdk版本即(1.7和1.8兩個(gè)jdk都可用)，非常具有實(shí)用價(jià)值，需要的朋友可以參考下
2017-11-11
Springboot如何實(shí)現(xiàn)對(duì)配置文件中的明文密碼加密
這篇文章主要介紹了Springboot如何實(shí)現(xiàn)對(duì)配置文件中的明文密碼加密問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教
2023-12-12
SpringBoot集成JWT實(shí)現(xiàn)登陸驗(yàn)證的方法詳解
JSON?Web?Token（JWT）是一個(gè)開放的標(biāo)準(zhǔn)（RFC?7519），它定義了一個(gè)緊湊且自包含的方式，用于在各方之間以JSON對(duì)象安全地傳輸信息。本文將利用SpringBoot集成JWT實(shí)現(xiàn)登陸驗(yàn)證，感興趣的可以了解一下
2022-05-05
java多線程實(shí)現(xiàn)下載圖片并壓縮
這篇文章主要為大家詳細(xì)介紹了java多線程實(shí)現(xiàn)下載圖片并壓縮，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
2018-05-05