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

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

Method Summary

Modifier and Type	Method	Description
Map<BaseGenericObjectPool.IdentityWrapper<S>,PooledObject<S>>	getAllObjects()	Gets all the objects for the current key.
AtomicInteger	getCreateCount()	Gets the number of instances created - number destroyed.
LinkedBlockingDeque<PooledObject<S>>	getIdleObjects()	Gets the idle objects for the current key.
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

public 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

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

Gets all the objects for the current key.

Returns:

All the objects

getCreateCount

public 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

public LinkedBlockingDeque<PooledObject<S>> getIdleObjects()

Gets the idle objects for the current key.

Returns:

The idle objects

getNumInterested

public 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