Java基于Semaphore构建阻塞对象池
更新时间：2020年04月24日 15:16:41 作者：flydean程序那些事
这篇文章主要介绍了Java基于Semaphore构建阻塞对象池,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
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
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
使用springboot单元测试对weblistener的加载测试
这篇文章主要介绍了使用springboot单元测试对weblistener的加载测试，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2021-10-10
springboot中用fastjson处理返回值为null的属性值
在本篇文章里小编给大家整理的是一篇关于springboot中用fastjson处理返回值问题详解内容，需要的朋友们参考下。2020-03-03
这篇文章主要为大家详细介绍了如何基于Java编写一个数据库比较工具类，其中比较结果会以现数据库的视角说明，感兴趣的小伙伴可以了解一下2023-07-07
本篇文章主要介绍了Spring配置多个数据源并实现动态切换示例，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看看吧2017-04-04
本文主要介绍了JPA与mybatis-plus不兼容问题的解决，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2023-02-02
这篇文章主要介绍了executor包执行器功能,executor包中的各个子包提供的功能，最终这些功能都由Executor接口及其实现类共同对外提供服务。下文介绍该执行功能，具有一定的参考价值，需要的朋友可以考一下2022-02-02
java截取字符串中的指定字符的两种方法(以base64图片为例)
本文介绍了使用Java截取字符串中指定字符的方法,通过substring索引和正则实现,文章详细介绍了实现步骤和示例代码,对于想要了解如何使用Java截取字符串指定字符的读者具有一定的参考价值2023-08-08
这篇文章主要介绍了Freemarker中的3种循环模式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2023-04-04
这篇文章主要介绍了Java中的i++与++i的实现原理详解,在Java中,i++是一种常见的递增操作符,用于将变量i的值增加1,它是一种简洁且方便的方式来实现循环和计数功能,i++可以用于各种情况,本文来看一下其实现原理,需要的朋友可以参考下2023-10-10
SpringBoot整合EasyExcel实现大规模数据的并行导出与压缩下载
在 Spring Boot 应用中,整合 EasyExcel 实现并行导出数据并进行 Zip 压缩下载可以极大地提高数据处理效率和用户体验,文中通过代码示例介绍的非常详细,具有一定的参考价值,需要的朋友可以参考下2024-10-10
最新评论