com.orientechnologies.common.concur.resource

Class OResourcePool<K,V>

java.lang.Object

com.orientechnologies.common.concur.resource.OResourcePool<K,V>

Type Parameters:

K - Resource's Key

V - Resource Object

Direct Known Subclasses:

OReentrantResourcePool

public class OResourcePool<K,V>
extends Object

Generic non reentrant implementation about pool of resources. It pre-allocates a semaphore of maxResources. Resources are lazily created by invoking the listener.

Author:

Luca Garulli (l.garulli--(at)--orientdb.com)

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicInteger	created
protected OResourcePoolListener<K,V>	listener
protected Queue<V>	resources
protected Queue<V>	resourcesOut
protected Semaphore	sem
protected Collection<V>	unmodifiableresources

Constructor Summary

Constructors

Constructor and Description
OResourcePool(int min, int max, OResourcePoolListener<K,V> listener)
OResourcePool(int max, OResourcePoolListener<K,V> listener)

Method Summary

Modifier and Type	Method and Description
void	close()
Collection<V>	getAllResources()
int	getAvailableResources()
int	getCreatedInstances()
int	getInPoolResources()
int	getMaxResources()
V	getResource(K key, long maxWaitMillis, Object... additionalArgs)
Collection<V>	getResources()
int	getResourcesOutCount()
void	remove(V res)
boolean	returnResource(V res)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

sem

protected final Semaphore sem

resources

protected final Queue<V> resources

resourcesOut

protected final Queue<V> resourcesOut

unmodifiableresources

protected final Collection<V> unmodifiableresources

listener

protected OResourcePoolListener<K,V> listener

created

protected final AtomicInteger created

Constructor Detail

OResourcePool

public OResourcePool(int max,
                     OResourcePoolListener<K,V> listener)

OResourcePool

public OResourcePool(int min,
                     int max,
                     OResourcePoolListener<K,V> listener)

Method Detail

getResource

public V getResource(K key,
                     long maxWaitMillis,
                     Object... additionalArgs)
              throws OAcquireTimeoutException

Throws:

OAcquireTimeoutException

getMaxResources

public int getMaxResources()

getAvailableResources

public int getAvailableResources()

getInPoolResources

public int getInPoolResources()

returnResource

public boolean returnResource(V res)

getResources

public Collection<V> getResources()

close

public void close()

getAllResources

public Collection<V> getAllResources()

remove

public void remove(V res)

getCreatedInstances

public int getCreatedInstances()

getResourcesOutCount

public int getResourcesOutCount()