Package com.orientechnologies.common.concur.resource

Class OReentrantResourcePool<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

OOrientShutdownListener, OOrientStartupListener

public class OReentrantResourcePool<K,V>
extends OResourcePool<K,V>
implements OOrientStartupListener, OOrientShutdownListener

Reentrant implementation of Resource Pool. It manages multiple resource acquisition on thread local map. If you're looking for a Reentrant implementation look at #OReentrantResourcePool.

Author:

Andrey Lomakin (a.lomakin-at-orientdb.com) (a.lomakin--at--orientdb.com), Luca Garulli (l.garulli--(at)--orientdb.com)

See Also:

• OResourcePool

Field Summary

Fields inherited from class com.orientechnologies.common.concur.resource.OResourcePool

created, listener, resources, resourcesOut, sem, unmodifiableresources

Constructor Summary

Constructors

Constructor	Description
OReentrantResourcePool(int maxResources, OResourcePoolListener<K,V> listener)

Method Summary

Modifier and Type	Method	Description
int	getConnectionsInCurrentThread(K key)
V	getResource(K key, long maxWaitMillis, Object... additionalArgs)
void	onShutdown()
void	onStartup()
void	remove(V res)
boolean	returnResource(V res)

Methods inherited from class com.orientechnologies.common.concur.resource.OResourcePool

close, getAllResources, getAvailableResources, getCreatedInstances, getInPoolResources, getMaxResources, getResources, getResourcesOutCount

Methods inherited from class java.lang.Object

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

Constructor Details

OReentrantResourcePool

public OReentrantResourcePool(int maxResources,
 OResourcePoolListener<K,V> listener)

Method Details

onShutdown

public void onShutdown()

Specified by:

onShutdown in interface OOrientShutdownListener

onStartup

public void onStartup()

Specified by:

onStartup in interface OOrientStartupListener

getResource

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

Overrides:

getResource in class OResourcePool<K,V>

Throws:

OLockException

returnResource

public boolean returnResource(V res)

Overrides:

returnResource in class OResourcePool<K,V>

getConnectionsInCurrentThread

public int getConnectionsInCurrentThread(K key)

remove

public void remove(V res)

Overrides:

remove in class OResourcePool<K,V>