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

更多精彩内容且看：

区块链从入门到放弃系列教程-涵盖密码学,超级账本,以太坊,Libra,比特币等持续更新
Spring Boot 2.X系列教程:七天从无到有掌握Spring Boot-持续更新
Spring 5.X系列教程:满足你对Spring5的一切想象-持续更新
java程序员从小工到专家成神之路（2020版）-持续更新中,附详细文章教程

更多内容请访问 flydean的博客

java中使用Semaphore构建阻塞对象池相关推荐

java堆和栈常量池_GitHub - han-guang-xue/difference-of-stack-heap-pool: Java中堆、栈和常量池的区别...
Java中堆.栈和常量池的区别栈堆常量池的概念首先我们先了解一下概念,Java把内存分成两种,一种叫做栈内存,一种叫做堆内存. 栈内存存放基本类型的变量数据和对象类型的引用(请注意存放的是引 ...
Java中堆、栈、常量池等概念解析
Java中堆.栈.常量池等概念解析程序运行时,我们最好对数据保存到什么地方做到心中有数.特别要注意的是内存的分配.有六个地方都可以保存数据: (1) 寄存器.这是最快的保存区域,因为它位于和其他所有 ...
Java中，一切皆是对象，为何数据类型中还分为：基本类型和对象？
Java中,一切皆是对象!为何数据类型中还分为:基本类型和对象?按理不应该只有一个类型-对象吗? 1.首先,Java中一切皆是对象!这句话没错,因为八种基本类型都有对应的包装类(int的包装类是Int ...
Java 中，类、类对象、泛型之间的转换
Java 中,类.类对象.泛型之间的转换 R 为非泛型获得类通过类型名来获得类通过对象来获得类通过类名字符串来获得类通过类来获得类名字符串通过类来获得对象使用 R 的无参数构造器来创建对 ...
Java中的垃圾回收与对象生命周期
转载自 Java中的垃圾回收与对象生命周期 1. 垃圾回收垃圾回收是Java程序设计中内存管理的核心概念,JVM的内存管理机制被称为垃圾回收机制. 一个对象创建后被放置在JVM的堆内存中,当永远 ...
Java中Comparable和Comparator实现对象比较
Java中Comparable和Comparator实现对象比较目录一. Comparator 二. Comparable 三.比较当需要排序的集合或数组不是单纯的数字型时,通常可以使用Comp ...
Java中创建（实例化）对象的五种方式
Java中创建(实例化)对象的五种方式 1.用new语句创建对象,这是最常见的创建对象的方法. 2.通过工厂方法返回对象,如:String str = String.valueOf(23); 3.运 ...
Java中的NIO非阻塞编程
在JDK1.4以前,Java的IO操作集中在java.io这个包中,是基于流的阻塞API.对于大多数应用来说,这样的API使用很方便,然而,一些对性能要求较高的应用,尤其是服务端应用,往往需要一个更为 ...
java中存在对多个对象加锁的情况_Java对象锁和类锁全面解析（多线程synchronized关键字）...
最近工作有用到一些多线程的东西,之前吧,有用到synchronized同步块,不过是别人怎么用就跟着用,并没有搞清楚锁的概念.最近也是遇到一些问题,不搞清楚锁的概念,很容易碰壁,甚至有些时候自己连用没 ...

java中使用Semaphore构建阻塞对象池

java中使用Semaphore构建阻塞对象池相关推荐

最新文章

热门文章