快捷導(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

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

您可能感興趣的文章:

相關(guān)文章

使用springboot單元測試對(duì)weblistener的加載測試
這篇文章主要介紹了使用springboot單元測試對(duì)weblistener的加載測試，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2021-10-10
springboot中用fastjson處理返回值為null的屬性值
在本篇文章里小編給大家整理的是一篇關(guān)于springboot中用fastjson處理返回值問題詳解內(nèi)容，需要的朋友們參考下。
2020-03-03
基于Java編寫一個(gè)數(shù)據(jù)庫比較工具類
這篇文章主要為大家詳細(xì)介紹了如何基于Java編寫一個(gè)數(shù)據(jù)庫比較工具類，其中比較結(jié)果會(huì)以現(xiàn)數(shù)據(jù)庫的視角說明，感興趣的小伙伴可以了解一下
2023-07-07
Spring配置多個(gè)數(shù)據(jù)源并實(shí)現(xiàn)動(dòng)態(tài)切換示例
本篇文章主要介紹了Spring配置多個(gè)數(shù)據(jù)源并實(shí)現(xiàn)動(dòng)態(tài)切換示例，小編覺得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過來看看吧
2017-04-04
JPA與mybatis-plus不兼容問題的解決
本文主要介紹了JPA與mybatis-plus不兼容問題的解決，文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧
2023-02-02
executor包執(zhí)行器功能
這篇文章主要介紹了executor包執(zhí)行器功能,executor包中的各個(gè)子包提供的功能，最終這些功能都由Executor接口及其實(shí)現(xiàn)類共同對(duì)外提供服務(wù)。下文介紹該執(zhí)行功能，具有一定的參考價(jià)值，需要的朋友可以考一下
2022-02-02
java截取字符串中的指定字符的兩種方法(以base64圖片為例)
本文介紹了使用Java截取字符串中指定字符的方法,通過substring索引和正則實(shí)現(xiàn),文章詳細(xì)介紹了實(shí)現(xiàn)步驟和示例代碼,對(duì)于想要了解如何使用Java截取字符串指定字符的讀者具有一定的參考價(jià)值
2023-08-08
Freemarker中的3種循環(huán)模式
這篇文章主要介紹了Freemarker中的3種循環(huán)模式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教
2023-04-04
Java中的遞增i++與++i的實(shí)現(xiàn)原理詳解
這篇文章主要介紹了Java中的i++與++i的實(shí)現(xiàn)原理詳解,在Java中,i++是一種常見的遞增操作符,用于將變量i的值增加1,它是一種簡潔且方便的方式來實(shí)現(xiàn)循環(huán)和計(jì)數(shù)功能,i++可以用于各種情況,本文來看一下其實(shí)現(xiàn)原理,需要的朋友可以參考下
2023-10-10
SpringBoot整合EasyExcel實(shí)現(xiàn)大規(guī)模數(shù)據(jù)的并行導(dǎo)出與壓縮下載
在 Spring Boot 應(yīng)用中,整合 EasyExcel 實(shí)現(xiàn)并行導(dǎo)出數(shù)據(jù)并進(jìn)行 Zip 壓縮下載可以極大地提高數(shù)據(jù)處理效率和用戶體驗(yàn),文中通過代碼示例介紹的非常詳細(xì),具有一定的參考價(jià)值,需要的朋友可以參考下
2024-10-10