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 and Description
OReentrantResourcePool(int maxResources, OResourcePoolListener<K,V> listener)

Method Summary

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

OReentrantResourcePool

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

Method Detail

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>