Package org.apache.commons.pool2.impl

Class GenericKeyedObjectPool.ObjectDeque<S>

java.lang.Object

org.apache.commons.pool2.impl.GenericKeyedObjectPool.ObjectDeque<S>

Type Parameters:

S - type of objects in the pool

Enclosing class:

GenericKeyedObjectPool<K,T>

private static final class GenericKeyedObjectPool.ObjectDeque<S>
extends Object

Maintains information on the per key queue for a given key.

Field Summary

Fields

Modifier and Type	Field	Description
private final Map<BaseGenericObjectPool.IdentityWrapper<S>,PooledObject<S>>	allObjects
private final AtomicInteger	createCount
private final LinkedBlockingDeque<PooledObject<S>>	idleObjects
private long	makeObjectCount
private final Object	makeObjectCountLock
private final AtomicLong	numInterested

Constructor Summary

Constructors

Modifier	Constructor	Description
private	ObjectDeque(boolean fairness)	Constructs a new ObjectDeque with the given fairness policy.

Method Summary

Modifier and Type	Method	Description
(package private) Map<BaseGenericObjectPool.IdentityWrapper<S>,PooledObject<S>>	getAllObjects()	Gets all the objects for the current key.
(package private) AtomicInteger	getCreateCount()	Gets the number of instances created - number destroyed.
(package private) LinkedBlockingDeque<PooledObject<S>>	getIdleObjects()	Gets the idle objects for the current key.
(package private) AtomicLong	getNumInterested()	Gets the number of threads with an interest registered in this key.
String	toString()

Methods inherited from class java.lang.Object

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

Field Details

idleObjects

private final LinkedBlockingDeque<PooledObject<S>> idleObjects

createCount

private final AtomicInteger createCount

makeObjectCount

private long makeObjectCount

makeObjectCountLock

private final Object makeObjectCountLock

allObjects

private final Map<BaseGenericObjectPool.IdentityWrapper<S>,PooledObject<S>> allObjects

numInterested

private final AtomicLong numInterested

Constructor Details

ObjectDeque

private ObjectDeque(boolean fairness)

Constructs a new ObjectDeque with the given fairness policy.

Parameters:

fairness - true means client threads waiting to borrow / return instances will be served as if waiting in a FIFO queue.

Method Details

getAllObjects

Map<BaseGenericObjectPool.IdentityWrapper<S>,PooledObject<S>> getAllObjects()

Gets all the objects for the current key.

Returns:

All the objects.

getCreateCount

AtomicInteger getCreateCount()

Gets the number of instances created - number destroyed. Should always be less than or equal to maxTotalPerKey.

Returns:

The net instance addition count for this deque.

getIdleObjects

LinkedBlockingDeque<PooledObject<S>> getIdleObjects()

Gets the idle objects for the current key.

Returns:

The idle objects.

getNumInterested

AtomicLong getNumInterested()

Gets the number of threads with an interest registered in this key.

Returns:

The number of threads with a registered interest in this key.

toString

public String toString()

Overrides:

toString in class Object