Java基于Semaphore構(gòu)建阻塞對(duì)象池
java中使用Semaphore構(gòu)建阻塞對(duì)象池
Semaphore是java 5中引入的概念，叫做計(jì)數(shù)信號(hào)量。主要用來(lái)控制同時(shí)訪問(wèn)某個(gè)特定資源的訪問(wèn)數(shù)量或者執(zhí)行某個(gè)操作的數(shù)量。
Semaphore中定義了一組虛擬的permits，通過(guò)獲取和釋放這些permits，Semaphore可以控制資源的個(gè)數(shù)。
Semaphore的這個(gè)特性可以用來(lái)構(gòu)造資源池，比如數(shù)據(jù)庫(kù)連接池等。
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用來(lái)獲取資源，release用來(lái)釋放資源。
有了這兩個(gè)特性， 我們看一下怎么使用Semaphore來(lái)定義一個(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í)有所幫助，也希望大家多多支持腳本之家。
- Java并發(fā)編程Semaphore計(jì)數(shù)信號(hào)量詳解
- Java并發(fā)編程之Semaphore（信號(hào)量）詳解及實(shí)例
- Java信號(hào)量Semaphore原理及代碼實(shí)例
- Java 信號(hào)量Semaphore的實(shí)現(xiàn)
- Java中Semaphore(信號(hào)量)的使用方法
- Java并發(fā)系列之Semaphore源碼分析
- Java并發(fā)編程：CountDownLatch與CyclicBarrier和Semaphore的實(shí)例詳解
- JAVA 多線程之信號(hào)量(Semaphore)實(shí)例詳解
- java線程并發(fā)semaphore類示例
- 分析Java并發(fā)編程之信號(hào)量Semaphore
相關(guān)文章
使用springboot單元測(cè)試對(duì)weblistener的加載測(cè)試
這篇文章主要介紹了使用springboot單元測(cè)試對(duì)weblistener的加載測(cè)試，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-10-10
springboot中用fastjson處理返回值為null的屬性值
在本篇文章里小編給大家整理的是一篇關(guān)于springboot中用fastjson處理返回值問(wèn)題詳解內(nèi)容，需要的朋友們參考下。2020-03-03
基于Java編寫一個(gè)數(shù)據(jù)庫(kù)比較工具類
這篇文章主要為大家詳細(xì)介紹了如何基于Java編寫一個(gè)數(shù)據(jù)庫(kù)比較工具類，其中比較結(jié)果會(huì)以現(xiàn)數(shù)據(jù)庫(kù)的視角說(shuō)明，感興趣的小伙伴可以了解一下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)切換示例，小編覺(jué)得挺不錯(cuò)的，現(xiàn)在分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2017-04-04
本文主要介紹了JPA與mybatis-plus不兼容問(wèn)題的解決，文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02
這篇文章主要介紹了executor包執(zhí)行器功能,executor包中的各個(gè)子包提供的功能，最終這些功能都由Executor接口及其實(shí)現(xiàn)類共同對(duì)外提供服務(wù)。下文介紹該執(zhí)行功能，具有一定的參考價(jià)值，需要的朋友可以考一下2022-02-02
java截取字符串中的指定字符的兩種方法(以base64圖片為例)
本文介紹了使用Java截取字符串中指定字符的方法,通過(guò)substring索引和正則實(shí)現(xiàn),文章詳細(xì)介紹了實(shí)現(xiàn)步驟和示例代碼,對(duì)于想要了解如何使用Java截取字符串指定字符的讀者具有一定的參考價(jià)值2023-08-08
這篇文章主要介紹了Freemarker中的3種循環(huán)模式，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2023-04-04
Java中的遞增i++與++i的實(shí)現(xiàn)原理詳解
這篇文章主要介紹了Java中的i++與++i的實(shí)現(xiàn)原理詳解,在Java中,i++是一種常見(jiàn)的遞增操作符,用于將變量i的值增加1,它是一種簡(jiǎn)潔且方便的方式來(lái)實(shí)現(xiàn)循環(huán)和計(jì)數(shù)功能,i++可以用于各種情況,本文來(lá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),文中通過(guò)代碼示例介紹的非常詳細(xì),具有一定的參考價(jià)值,需要的朋友可以參考下2024-10-10