Index
All Classes and Interfaces|All Packages|Constant Field Values
A
- afterReduce(int, int, Throwable) - Method in class org.vibur.objectpool.util.SamplingPoolReducer
-
An after reduce pool hook.
- ArgumentValidation - Class in org.vibur.objectpool.util
B
- BasePool - Interface in org.vibur.objectpool
-
Defines the base object pool operations.
C
- calculateReduction() - Method in class org.vibur.objectpool.util.SamplingPoolReducer
-
Calculates the number of currently allocated on the pool elements that needs to be destroyed/deallocated, as a result of the stats collected during the just finished observational time period.
- close() - Method in interface org.vibur.objectpool.BasePool
-
A synonym for
BasePool.terminate(). - close() - Method in class org.vibur.objectpool.ConcurrentPool
- ConcurrentCollection<T> - Interface in org.vibur.objectpool.util
-
An adapter interface to a concurrent collection that provides 4 access methods:
ConcurrentCollection.offerFirst(T),ConcurrentCollection.offerLast(T),ConcurrentCollection.pollFirst(), andConcurrentCollection.pollLast(). - ConcurrentLinkedDequeCollection<T> - Class in org.vibur.objectpool.util
-
A
ConcurrentLinkedDequebased implementation ofConcurrentCollection. - ConcurrentLinkedDequeCollection() - Constructor for class org.vibur.objectpool.util.ConcurrentLinkedDequeCollection
- ConcurrentLinkedQueueCollection<T> - Class in org.vibur.objectpool.util
-
A
ConcurrentLinkedQueuebased implementation ofConcurrentCollection. - ConcurrentLinkedQueueCollection() - Constructor for class org.vibur.objectpool.util.ConcurrentLinkedQueueCollection
- ConcurrentPool<T> - Class in org.vibur.objectpool
-
An object pool based on a
ConcurrentCollectionguarded by aSemaphore. - ConcurrentPool(ConcurrentCollection<T>, PoolObjectFactory<T>, int, int, boolean) - Constructor for class org.vibur.objectpool.ConcurrentPool
-
Creates a new
ConcurrentPoolwith the givenPoolObjectFactory, initial and max sizes, and fairness setting. - ConcurrentPool(ConcurrentCollection<T>, PoolObjectFactory<T>, int, int, boolean, Listener<T>) - Constructor for class org.vibur.objectpool.ConcurrentPool
-
Creates a new
ConcurrentPoolwith the givenPoolObjectFactory, initial and max sizes, and fairness setting. - ConcurrentStackCollection<T> - Class in org.vibur.objectpool.util
-
A
ConcurrentStackbased implementation ofConcurrentCollection. - ConcurrentStackCollection(int) - Constructor for class org.vibur.objectpool.util.ConcurrentStackCollection
- create() - Method in interface org.vibur.objectpool.PoolObjectFactory
-
Creates a new object for the calling object pool.
- createdTotal() - Method in interface org.vibur.objectpool.BasePool
-
Returns the total number of created objects which currently exist for this object pool.
- createdTotal() - Method in class org.vibur.objectpool.ConcurrentPool
D
- destroy(T) - Method in interface org.vibur.objectpool.PoolObjectFactory
-
A method which will be called when an object from the object pool needs to be destroyed, which is when the
PoolObjectFactory.readyToTake(T)orPoolObjectFactory.readyToRestore(T)methods have returnedfalse, or when the pool is shrinking its size (via callingreduceCreatedBy/To), or when the pool is terminating. - drainCreated() - Method in interface org.vibur.objectpool.BasePool
-
Tries to remove (and destroy) as many created objects from this object pool as possible.
- drainCreated() - Method in class org.vibur.objectpool.ConcurrentPool
F
- forbidIllegalArgument(boolean) - Static method in class org.vibur.objectpool.util.ArgumentValidation
- forbidIllegalArgument(boolean, String) - Static method in class org.vibur.objectpool.util.ArgumentValidation
G
- getState() - Method in class org.vibur.objectpool.util.SamplingPoolReducer
- getState() - Method in interface org.vibur.objectpool.util.ThreadedPoolReducer
-
Returns the state of the underlying thread.
- getTaken(T[]) - Method in class org.vibur.objectpool.util.TakenListener
- getThreadName() - Method in class org.vibur.objectpool.util.SamplingPoolReducer
I
- initialSize() - Method in interface org.vibur.objectpool.BasePool
-
Returns the
initialSizeof this object pool at construction time. - initialSize() - Method in class org.vibur.objectpool.ConcurrentPool
- isFair() - Method in class org.vibur.objectpool.ConcurrentPool
- isFair() - Method in interface org.vibur.objectpool.PoolService
-
Returns the fairness setting of this object pool.
- isTerminated() - Method in interface org.vibur.objectpool.BasePool
-
Returns the current terminated state of this object pool.
- isTerminated() - Method in class org.vibur.objectpool.ConcurrentPool
L
- listener() - Method in class org.vibur.objectpool.ConcurrentPool
- listener() - Method in interface org.vibur.objectpool.PoolService
-
Returns the
Listenerinterface instance associated with this object pool, if any. - Listener<T> - Interface in org.vibur.objectpool.util
-
An instance of this interface can be supplied to the pool at its creation time, and its methods will be called upon calling the pool
takeandrestoreoperations.
M
- MAX_REDUCTION_FRACTION - Static variable in class org.vibur.objectpool.util.SamplingPoolReducer
- maxSize() - Method in interface org.vibur.objectpool.BasePool
-
Returns the
maxSizeof this object pool. - maxSize() - Method in class org.vibur.objectpool.ConcurrentPool
- minRemainingCreated - Variable in class org.vibur.objectpool.util.SamplingPoolReducer
- MultithreadConcurrentQueueCollection<T> - Class in org.vibur.objectpool.util
-
A
MultithreadConcurrentQueuebased implementation ofConcurrentCollection. - MultithreadConcurrentQueueCollection(int) - Constructor for class org.vibur.objectpool.util.MultithreadConcurrentQueueCollection
O
- offerFirst(T) - Method in interface org.vibur.objectpool.util.ConcurrentCollection
-
Adds the given
objectat the head of theConcurrentCollection. - offerFirst(T) - Method in class org.vibur.objectpool.util.ConcurrentLinkedDequeCollection
- offerFirst(T) - Method in class org.vibur.objectpool.util.ConcurrentLinkedQueueCollection
- offerFirst(T) - Method in class org.vibur.objectpool.util.ConcurrentStackCollection
- offerFirst(T) - Method in class org.vibur.objectpool.util.MultithreadConcurrentQueueCollection
- offerLast(T) - Method in interface org.vibur.objectpool.util.ConcurrentCollection
-
Adds the given
objectat the tail of theConcurrentCollection. - offerLast(T) - Method in class org.vibur.objectpool.util.ConcurrentLinkedDequeCollection
- offerLast(T) - Method in class org.vibur.objectpool.util.ConcurrentLinkedQueueCollection
- offerLast(T) - Method in class org.vibur.objectpool.util.ConcurrentStackCollection
- offerLast(T) - Method in class org.vibur.objectpool.util.MultithreadConcurrentQueueCollection
- onRestore(T, boolean) - Method in interface org.vibur.objectpool.util.Listener
- onRestore(T, boolean) - Method in class org.vibur.objectpool.util.TakenListener
- onTake(T) - Method in interface org.vibur.objectpool.util.Listener
- onTake(T) - Method in class org.vibur.objectpool.util.TakenListener
- org.vibur.objectpool - package org.vibur.objectpool
- org.vibur.objectpool.util - package org.vibur.objectpool.util
P
- pollFirst() - Method in interface org.vibur.objectpool.util.ConcurrentCollection
-
Polls an
objectfrom the head of theConcurrentCollection. - pollFirst() - Method in class org.vibur.objectpool.util.ConcurrentLinkedDequeCollection
- pollFirst() - Method in class org.vibur.objectpool.util.ConcurrentLinkedQueueCollection
- pollFirst() - Method in class org.vibur.objectpool.util.ConcurrentStackCollection
- pollFirst() - Method in class org.vibur.objectpool.util.MultithreadConcurrentQueueCollection
- pollLast() - Method in interface org.vibur.objectpool.util.ConcurrentCollection
-
Polls an
objectfrom the tail of theConcurrentCollection. - pollLast() - Method in class org.vibur.objectpool.util.ConcurrentLinkedDequeCollection
- pollLast() - Method in class org.vibur.objectpool.util.ConcurrentLinkedQueueCollection
- pollLast() - Method in class org.vibur.objectpool.util.ConcurrentStackCollection
- pollLast() - Method in class org.vibur.objectpool.util.MultithreadConcurrentQueueCollection
- PoolObjectFactory<T> - Interface in org.vibur.objectpool
-
Defines the interface that will be implemented by the factory used by the object pools defined in the package, in order to control the lifecycle of the objects in the pools.
- PoolService<T> - Interface in org.vibur.objectpool
-
Defines the object pool operations.
R
- readyToRestore(T) - Method in interface org.vibur.objectpool.PoolObjectFactory
-
A validation/passivation hook which will be called by the
restoremethods ofConcurrentPoolwhen an object taken before that from the object pool is about to be restored (returned back) to the pool. - readyToTake(T) - Method in interface org.vibur.objectpool.PoolObjectFactory
-
A validation/activation hook which will be called by the
take...methods ofConcurrentPoolwhen an object from the object pool is requested by the application. - reduceCreatedBy(int, boolean) - Method in interface org.vibur.objectpool.BasePool
-
Tries to remove (and destroy) up to
reduceByobjects from the object pool. - reduceCreatedBy(int, boolean) - Method in class org.vibur.objectpool.ConcurrentPool
- reduceCreatedTo(int, boolean) - Method in interface org.vibur.objectpool.BasePool
-
Tries to remove (and destroy) such number of objects from the object pool that the number of
BasePool.createdTotal()objects in the pool to become equal ofreduceTo. - reduceCreatedTo(int, boolean) - Method in class org.vibur.objectpool.ConcurrentPool
- reducePool() - Method in class org.vibur.objectpool.util.SamplingPoolReducer
- remainingCapacity() - Method in interface org.vibur.objectpool.BasePool
-
Returns the remaining capacity of this object pool, i.e. the number of objects which could be taken from this object pool without blocking.
- remainingCapacity() - Method in class org.vibur.objectpool.ConcurrentPool
- remainingCreated() - Method in interface org.vibur.objectpool.BasePool
-
Returns the number of remaining created objects which are currently available in this object pool.
- remainingCreated() - Method in class org.vibur.objectpool.ConcurrentPool
- restore(T) - Method in class org.vibur.objectpool.ConcurrentPool
- restore(T) - Method in interface org.vibur.objectpool.PoolService
-
Restores (returns) an object to the object pool.
- restore(T, boolean) - Method in class org.vibur.objectpool.ConcurrentPool
- restore(T, boolean) - Method in interface org.vibur.objectpool.PoolService
-
Restores (returns) an object to the object pool.
S
- samplePool() - Method in class org.vibur.objectpool.util.SamplingPoolReducer
- SamplingPoolReducer - Class in org.vibur.objectpool.util
-
A sampling pool reducer util, which is awakened up a given number of times during a predefined period of time, and checks whether the number of available allocated objects in the object pool needs to be reduced.
- SamplingPoolReducer(BasePool, long, TimeUnit, int) - Constructor for class org.vibur.objectpool.util.SamplingPoolReducer
- size() - Method in interface org.vibur.objectpool.util.ConcurrentCollection
-
Returns the number of elements in this collection.
- size() - Method in class org.vibur.objectpool.util.ConcurrentLinkedDequeCollection
- size() - Method in class org.vibur.objectpool.util.ConcurrentLinkedQueueCollection
- size() - Method in class org.vibur.objectpool.util.ConcurrentStackCollection
- size() - Method in class org.vibur.objectpool.util.MultithreadConcurrentQueueCollection
- start() - Method in class org.vibur.objectpool.util.SamplingPoolReducer
- start() - Method in interface org.vibur.objectpool.util.ThreadedPoolReducer
-
Starts this pool reducer, which starts its underlying daemon thread.
T
- take() - Method in class org.vibur.objectpool.ConcurrentPool
- take() - Method in interface org.vibur.objectpool.PoolService
-
A counterpart of
PoolService.take(long[])that does not report back the time waited to obtain an object from the pool. - take(long[]) - Method in class org.vibur.objectpool.ConcurrentPool
- take(long[]) - Method in interface org.vibur.objectpool.PoolService
-
Takes an object from the object pool if there is such available.
- taken() - Method in interface org.vibur.objectpool.BasePool
-
Returns the number of objects taken from this object pool.
- taken() - Method in class org.vibur.objectpool.ConcurrentPool
- TakenListener<T> - Class in org.vibur.objectpool.util
-
An instance of this class can be supplied to the pool at its creation time, and its methods will be called upon calling the pool take and restore operations.
- TakenListener() - Constructor for class org.vibur.objectpool.util.TakenListener
- TakenListener(int) - Constructor for class org.vibur.objectpool.util.TakenListener
- takeUninterruptibly() - Method in class org.vibur.objectpool.ConcurrentPool
- takeUninterruptibly() - Method in interface org.vibur.objectpool.PoolService
-
A counterpart of
PoolService.takeUninterruptibly(long[])that does not report back the time waited to obtain an object from the pool. - takeUninterruptibly(long[]) - Method in class org.vibur.objectpool.ConcurrentPool
- takeUninterruptibly(long[]) - Method in interface org.vibur.objectpool.PoolService
-
Takes an object from the object pool if there is such available.
- terminate() - Method in interface org.vibur.objectpool.BasePool
-
Terminates this object pool.
- terminate() - Method in class org.vibur.objectpool.ConcurrentPool
- terminate() - Method in class org.vibur.objectpool.util.SamplingPoolReducer
- terminate() - Method in interface org.vibur.objectpool.util.ThreadedPoolReducer
-
Terminates this pool reducer, which terminates its underlying daemon thread.
- ThreadedPoolReducer - Interface in org.vibur.objectpool.util
-
The pool reducers implementing this interface will create one daemon service thread which will be started when the reducer's
start()method is called, and will be alive until theterminate()method is called or until the calling application exits. - toString() - Method in class org.vibur.objectpool.ConcurrentPool
- tryTake() - Method in class org.vibur.objectpool.ConcurrentPool
- tryTake() - Method in interface org.vibur.objectpool.PoolService
-
Tries to take an object from the object pool if there is one that is immediately available; the object may need to be created as described in
PoolService.tryTake(long, TimeUnit, long[]). - tryTake(long, TimeUnit) - Method in class org.vibur.objectpool.ConcurrentPool
- tryTake(long, TimeUnit) - Method in interface org.vibur.objectpool.PoolService
-
A counterpart of
PoolService.tryTake(long, TimeUnit, long[])that does not report back the time waited to obtain an object from the pool. - tryTake(long, TimeUnit, long[]) - Method in class org.vibur.objectpool.ConcurrentPool
- tryTake(long, TimeUnit, long[]) - Method in interface org.vibur.objectpool.PoolService
-
Tries to take an object from the object pool if there is one available.
All Classes and Interfaces|All Packages|Constant Field Values