Package 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	Description
protected final AtomicInteger	created
protected OResourcePoolListener<K,V>	listener
protected final Queue<V>	resources
protected final Queue<V>	resourcesOut
protected final Semaphore	sem
protected final Collection<V>	unmodifiableresources

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	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 Details

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 Details

OResourcePool

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

OResourcePool

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

Method Details

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()