T
- Type of element pooled in this pool.public class GenericObjectPool<T> extends BaseGenericObjectPool<T> implements ObjectPool<T>, GenericObjectPoolMXBean, UsageTracking<T>
ObjectPool
implementation.
When coupled with the appropriate PooledObjectFactory
,
GenericObjectPool
provides robust pooling functionality for
arbitrary objects.
Optionally, one may configure the pool to examine and possibly evict objects as they sit idle in the pool and to ensure that a minimum number of idle objects are available. This is performed by an "idle object eviction" thread, which runs asynchronously. Caution should be used when configuring this optional feature. Eviction runs contend with client threads for access to objects in the pool, so if they run too frequently performance issues may result.
The pool can also be configured to detect and remove "abandoned" objects,
i.e. objects that have been checked out of the pool but neither used nor
returned before the configured
removeAbandonedTimeout
.
Abandoned object removal can be configured to happen when
borrowObject
is invoked and the pool is close to starvation, or
it can be executed by the idle object evictor, or both. If pooled objects
implement the TrackedUse
interface,
their last use will be queried
using the getLastUsed
method on that interface; otherwise
abandonment is determined by how long an object has been checked out from
the pool.
Implementation note: To prevent possible deadlocks, care has been taken to ensure that no call to a factory method will occur within a synchronization block. See POOL-125 and DBCP-44 for more information.
This class is intended to be thread-safe.
GenericKeyedObjectPool
MEAN_TIMING_STATS_CACHE_SIZE
Constructor and Description |
---|
GenericObjectPool(PooledObjectFactory<T> factory)
Create a new
GenericObjectPool using defaults from
GenericObjectPoolConfig . |
GenericObjectPool(PooledObjectFactory<T> factory,
GenericObjectPoolConfig config)
Create a new
GenericObjectPool using a specific
configuration. |
GenericObjectPool(PooledObjectFactory<T> factory,
GenericObjectPoolConfig config,
AbandonedConfig abandonedConfig)
Create a new
GenericObjectPool that tracks and destroys
objects that are checked out, but never returned to the pool. |
Modifier and Type | Method and Description |
---|---|
void |
addObject()
Create an object, and place it into the pool. addObject() is useful for
"pre-loading" a pool with idle objects.
|
T |
borrowObject()
Equivalent to
. |
T |
borrowObject(long borrowMaxWaitMillis)
Borrow an object from the pool using the specific waiting time which only
applies if
BaseGenericObjectPool.getBlockWhenExhausted() is true. |
void |
clear()
Clears any objects sitting idle in the pool by removing them from the
idle instance pool and then invoking the configured
PooledObjectFactory.destroyObject(PooledObject) method on each
idle instance. |
void |
close()
Closes the pool.
|
void |
evict()
Perform
numTests idle object eviction tests, evicting
examined objects that meet the criteria for eviction. |
PooledObjectFactory<T> |
getFactory()
Obtain a reference to the factory used to create, destroy and validate
the objects used by this pool.
|
String |
getFactoryType()
Return the type - including the specific type rather than the generic -
of the factory.
|
boolean |
getLogAbandoned()
Will this pool identify and log any abandoned objects?
|
int |
getMaxIdle()
Returns the cap on the number of "idle" instances in the pool.
|
int |
getMinIdle()
Returns the target for the minimum number of idle objects to maintain in
the pool.
|
int |
getNumActive()
Return the number of instances currently borrowed from this pool.
|
int |
getNumIdle()
The number of instances currently idle in this pool.
|
int |
getNumWaiters()
Return an estimate of the number of threads currently blocked waiting for
an object from the pool.
|
boolean |
getRemoveAbandonedOnBorrow()
Will a check be made for abandoned objects when an object is borrowed
from this pool?
|
boolean |
getRemoveAbandonedOnMaintenance()
Will a check be made for abandoned objects when the evictor runs?
|
int |
getRemoveAbandonedTimeout()
Obtain the timeout before which an object will be considered to be
abandoned by this pool.
|
void |
invalidateObject(T obj)
Invalidates an object from the pool.
|
boolean |
isAbandonedConfig()
Whether or not abandoned object removal is configured for this pool.
|
Set<DefaultPooledObjectInfo> |
listAllObjects()
Provides information on all the objects in the pool, both idle (waiting
to be borrowed) and active (currently borrowed).
|
void |
returnObject(T obj)
Return an instance to the pool.
|
void |
setAbandonedConfig(AbandonedConfig abandonedConfig)
Sets the abandoned object removal configuration.
|
void |
setConfig(GenericObjectPoolConfig conf)
Sets the base pool configuration.
|
void |
setMaxIdle(int maxIdle)
Returns the cap on the number of "idle" instances in the pool.
|
void |
setMinIdle(int minIdle)
Sets the target for the minimum number of idle objects to maintain in
the pool.
|
void |
use(T pooledObject)
This method is called every time a pooled object to enable the pool to
better track borrowed objects.
|
getBlockWhenExhausted, getBorrowedCount, getCreatedCount, getCreationStackTrace, getDestroyedByBorrowValidationCount, getDestroyedByEvictorCount, getDestroyedCount, getEvictionPolicyClassName, getFairness, getJmxName, getLifo, getMaxBorrowWaitTimeMillis, getMaxTotal, getMaxWaitMillis, getMeanActiveTimeMillis, getMeanBorrowWaitTimeMillis, getMeanIdleTimeMillis, getMinEvictableIdleTimeMillis, getNumTestsPerEvictionRun, getReturnedCount, getSoftMinEvictableIdleTimeMillis, getSwallowedExceptionListener, getTestOnBorrow, getTestOnCreate, getTestOnReturn, getTestWhileIdle, getTimeBetweenEvictionRunsMillis, isClosed, setBlockWhenExhausted, setEvictionPolicyClassName, setLifo, setMaxTotal, setMaxWaitMillis, setMinEvictableIdleTimeMillis, setNumTestsPerEvictionRun, setSoftMinEvictableIdleTimeMillis, setSwallowedExceptionListener, setTestOnBorrow, setTestOnCreate, setTestOnReturn, setTestWhileIdle, setTimeBetweenEvictionRunsMillis
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getBlockWhenExhausted, getBorrowedCount, getCreatedCount, getCreationStackTrace, getDestroyedByBorrowValidationCount, getDestroyedByEvictorCount, getDestroyedCount, getFairness, getLifo, getMaxBorrowWaitTimeMillis, getMaxTotal, getMaxWaitMillis, getMeanActiveTimeMillis, getMeanBorrowWaitTimeMillis, getMeanIdleTimeMillis, getMinEvictableIdleTimeMillis, getNumTestsPerEvictionRun, getReturnedCount, getTestOnBorrow, getTestOnCreate, getTestOnReturn, getTestWhileIdle, getTimeBetweenEvictionRunsMillis, isClosed
public GenericObjectPool(PooledObjectFactory<T> factory)
GenericObjectPool
using defaults from
GenericObjectPoolConfig
.factory
- The object factory to be used to create object instances
used by this poolpublic GenericObjectPool(PooledObjectFactory<T> factory, GenericObjectPoolConfig config)
GenericObjectPool
using a specific
configuration.factory
- The object factory to be used to create object instances
used by this poolconfig
- The configuration to use for this pool instance. The
configuration is used by value. Subsequent changes to
the configuration object will not be reflected in the
pool.public GenericObjectPool(PooledObjectFactory<T> factory, GenericObjectPoolConfig config, AbandonedConfig abandonedConfig)
GenericObjectPool
that tracks and destroys
objects that are checked out, but never returned to the pool.factory
- The object factory to be used to create object instances
used by this poolconfig
- The base pool configuration to use for this pool instance.
The configuration is used by value. Subsequent changes to
the configuration object will not be reflected in the
pool.abandonedConfig
- Configuration for abandoned object identification
and removal. The configuration is used by value.public int getMaxIdle()
getMaxIdle
in interface GenericObjectPoolMXBean
setMaxIdle(int)
public void setMaxIdle(int maxIdle)
maxIdle
- The cap on the number of "idle" instances in the pool. Use a
negative value to indicate an unlimited number of idle
instancesgetMaxIdle()
public void setMinIdle(int minIdle)
BaseGenericObjectPool.getTimeBetweenEvictionRunsMillis()
is greater than zero. If this
is the case, an attempt is made to ensure that the pool has the required
minimum number of instances during idle object eviction runs.
If the configured value of minIdle is greater than the configured value for maxIdle then the value of maxIdle will be used instead.
minIdle
- The minimum number of objects.getMinIdle()
,
getMaxIdle()
,
BaseGenericObjectPool.getTimeBetweenEvictionRunsMillis()
public int getMinIdle()
BaseGenericObjectPool.getTimeBetweenEvictionRunsMillis()
is greater than zero. If this
is the case, an attempt is made to ensure that the pool has the required
minimum number of instances during idle object eviction runs.
If the configured value of minIdle is greater than the configured value for maxIdle then the value of maxIdle will be used instead.
getMinIdle
in interface GenericObjectPoolMXBean
setMinIdle(int)
,
setMaxIdle(int)
,
BaseGenericObjectPool.setTimeBetweenEvictionRunsMillis(long)
public boolean isAbandonedConfig()
isAbandonedConfig
in interface GenericObjectPoolMXBean
public boolean getLogAbandoned()
getLogAbandoned
in interface GenericObjectPoolMXBean
true
if abandoned object removal is configured for this
pool and removal events are to be logged otherwise false
AbandonedConfig.getLogAbandoned()
public boolean getRemoveAbandonedOnBorrow()
getRemoveAbandonedOnBorrow
in interface GenericObjectPoolMXBean
true
if abandoned object removal is configured to be
activated by borrowObject otherwise false
AbandonedConfig.getRemoveAbandonedOnBorrow()
public boolean getRemoveAbandonedOnMaintenance()
getRemoveAbandonedOnMaintenance
in interface GenericObjectPoolMXBean
true
if abandoned object removal is configured to be
activated when the evictor runs otherwise false
AbandonedConfig.getRemoveAbandonedOnMaintenance()
public int getRemoveAbandonedTimeout()
getRemoveAbandonedTimeout
in interface GenericObjectPoolMXBean
AbandonedConfig.getRemoveAbandonedTimeout()
public void setConfig(GenericObjectPoolConfig conf)
conf
- the new configuration to use. This is used by value.GenericObjectPoolConfig
public void setAbandonedConfig(AbandonedConfig abandonedConfig) throws IllegalArgumentException
abandonedConfig
- the new configuration to use. This is used by value.IllegalArgumentException
AbandonedConfig
public PooledObjectFactory<T> getFactory()
public T borrowObject() throws Exception
borrowObject
(BaseGenericObjectPool.getMaxWaitMillis()
)
.
Obtains an instance from this pool.
Instances returned from this method will have been either newly created
with PooledObjectFactory.makeObject()
or will be a previously
idle object and have been activated with
PooledObjectFactory.activateObject(org.apache.tomcat.dbcp.pool2.PooledObject<T>)
and then validated with
PooledObjectFactory.validateObject(org.apache.tomcat.dbcp.pool2.PooledObject<T>)
.
By contract, clients must return the borrowed instance
using ObjectPool.returnObject(T)
, ObjectPool.invalidateObject(T)
, or a related
method as defined in an implementation or sub-interface.
The behaviour of this method when the pool has been exhausted is not strictly specified (although it may be specified by implementations).
borrowObject
in interface ObjectPool<T>
IllegalStateException
- after close
has been called on this pool.Exception
- when PooledObjectFactory.makeObject()
throws an
exception.NoSuchElementException
- when the pool is exhausted and cannot or will not return
another instance.public T borrowObject(long borrowMaxWaitMillis) throws Exception
BaseGenericObjectPool.getBlockWhenExhausted()
is true.
If there is one or more idle instance available in the pool, then an
idle instance will be selected based on the value of BaseGenericObjectPool.getLifo()
,
activated and returned. If activation fails, or testOnBorrow
is set to true
and validation fails, the
instance is destroyed and the next available instance is examined. This
continues until either a valid instance is returned or there are no more
idle instances available.
If there are no idle instances available in the pool, behavior depends on
the maxTotal
, (if applicable)
BaseGenericObjectPool.getBlockWhenExhausted()
and the value passed in to the
borrowMaxWaitMillis
parameter. If the number of instances
checked out from the pool is less than maxTotal,
a new
instance is created, activated and (if applicable) validated and returned
to the caller. If validation fails, a NoSuchElementException
is thrown.
If the pool is exhausted (no available idle instances and no capacity to
create new ones), this method will either block (if
BaseGenericObjectPool.getBlockWhenExhausted()
is true) or throw a
NoSuchElementException
(if
BaseGenericObjectPool.getBlockWhenExhausted()
is false). The length of time that this
method will block when BaseGenericObjectPool.getBlockWhenExhausted()
is true is
determined by the value passed in to the borrowMaxWaitMillis
parameter.
When the pool is exhausted, multiple calling threads may be simultaneously blocked waiting for instances to become available. A "fairness" algorithm has been implemented to ensure that threads receive available instances in request arrival order.
borrowMaxWaitMillis
- The time to wait in milliseconds for an object
to become availableNoSuchElementException
- if an instance cannot be returnedException
- if an object instance cannot be returned due to an
errorpublic void returnObject(T obj)
obj
must have been obtained using ObjectPool.borrowObject()
or
a related method as defined in an implementation or sub-interface.
If maxIdle
is set to a positive value and the
number of idle instances has reached this value, the returning instance
is destroyed.
If testOnReturn
== true, the returning
instance is validated before being returned to the idle instance pool. In
this case, if validation fails, the instance is destroyed.
Exceptions encountered destroying objects for any reason are swallowed
but notified via a
SwallowedExceptionListener
.
returnObject
in interface ObjectPool<T>
obj
- a borrowed
instance to be returned.public void invalidateObject(T obj) throws Exception
By contract, obj
must have been obtained
using ObjectPool.borrowObject()
or a related method as defined in an
implementation or sub-interface.
This method should be used when an object that has been borrowed is determined (due to an exception or other problem) to be invalid.
Activation of this method decrements the active count and attempts to destroy the instance.
invalidateObject
in interface ObjectPool<T>
obj
- a borrowed
instance to be disposed.Exception
- if an exception occurs destroying the
objectIllegalStateException
- if obj does not belong to this poolpublic void clear()
PooledObjectFactory.destroyObject(PooledObject)
method on each
idle instance.
Implementation notes:
SwallowedExceptionListener
.clear
in interface ObjectPool<T>
public int getNumActive()
ObjectPool
getNumActive
in interface GenericObjectPoolMXBean
getNumActive
in interface ObjectPool<T>
public int getNumIdle()
BaseGenericObjectPool
getNumIdle
in interface GenericObjectPoolMXBean
getNumIdle
in interface ObjectPool<T>
getNumIdle
in class BaseGenericObjectPool<T>
public void close()
borrowObject()
will
fail with IllegalStateException, but returnObject(Object)
and
invalidateObject(Object)
will continue to work, with returned
objects destroyed on return.
Destroys idle instances in the pool by invoking clear()
.
close
in interface ObjectPool<T>
close
in class BaseGenericObjectPool<T>
public void evict() throws Exception
Perform numTests
idle object eviction tests, evicting
examined objects that meet the criteria for eviction. If
testWhileIdle
is true, examined objects are validated
when visited (and removed if invalid); otherwise only objects that
have been idle for more than minEvicableIdleTimeMillis
are removed.
Successive activations of this method examine objects in sequence, cycling through objects in oldest-to-youngest order.
evict
in class BaseGenericObjectPool<T>
Exception
- when there is a problem evicting idle objects.public void addObject() throws Exception
addObject
in interface ObjectPool<T>
Exception
- when PooledObjectFactory.makeObject()
fails.IllegalStateException
- after ObjectPool.close()
has been called on this pool.UnsupportedOperationException
- when this pool cannot add new idle objects.public void use(T pooledObject)
UsageTracking
use
in interface UsageTracking<T>
pooledObject
- The object that is being usedpublic int getNumWaiters()
getNumWaiters
in interface GenericObjectPoolMXBean
public String getFactoryType()
getFactoryType
in interface GenericObjectPoolMXBean
public Set<DefaultPooledObjectInfo> listAllObjects()
Note: This is named listAllObjects so it is presented as an operation via JMX. That means it won't be invoked unless the explicitly requested whereas all attributes will be automatically requested when viewing the attributes for an object in a tool like JConsole.
listAllObjects
in interface GenericObjectPoolMXBean
Copyright © 2000-2014 Apache Software Foundation. All Rights Reserved.