public final class PoolUtils
extends java.lang.Object
Constructor and Description |
---|
PoolUtils()
PoolUtils instances should NOT be constructed in standard programming.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> java.util.Map<K,java.util.TimerTask> |
checkMinIdle(KeyedObjectPool<K,V> keyedPool,
java.util.Collection<K> keys,
int minIdle,
long period)
Periodically check the idle object count for each key in the
Collection keys in the keyedPool. |
static <K,V> java.util.TimerTask |
checkMinIdle(KeyedObjectPool<K,V> keyedPool,
K key,
int minIdle,
long period)
Periodically check the idle object count for the key in the keyedPool.
|
static <T> java.util.TimerTask |
checkMinIdle(ObjectPool<T> pool,
int minIdle,
long period)
Periodically check the idle object count for the pool.
|
static void |
checkRethrow(java.lang.Throwable t)
Should the supplied Throwable be re-thrown (eg if it is an instance of
one of the Throwables that should never be swallowed).
|
static <K,V> KeyedObjectPool<K,V> |
erodingPool(KeyedObjectPool<K,V> keyedPool)
Returns a pool that adaptively decreases its size when idle objects are
no longer needed.
|
static <K,V> KeyedObjectPool<K,V> |
erodingPool(KeyedObjectPool<K,V> keyedPool,
float factor)
Returns a pool that adaptively decreases its size when idle objects are
no longer needed.
|
static <K,V> KeyedObjectPool<K,V> |
erodingPool(KeyedObjectPool<K,V> keyedPool,
float factor,
boolean perKey)
Returns a pool that adaptively decreases its size when idle objects are
no longer needed.
|
static <T> ObjectPool<T> |
erodingPool(ObjectPool<T> pool)
Returns a pool that adaptively decreases its size when idle objects are
no longer needed.
|
static <T> ObjectPool<T> |
erodingPool(ObjectPool<T> pool,
float factor)
Returns a pool that adaptively decreases its size when idle objects are
no longer needed.
|
static <K,V> void |
prefill(KeyedObjectPool<K,V> keyedPool,
java.util.Collection<K> keys,
int count)
Calls
KeyedObjectPool.addObject(Object) on keyedPool with each
key in keys for count number of times. |
static <K,V> void |
prefill(KeyedObjectPool<K,V> keyedPool,
K key,
int count)
|
static <T> void |
prefill(ObjectPool<T> pool,
int count)
|
static <K,V> KeyedPooledObjectFactory<K,V> |
synchronizedKeyedPooledFactory(KeyedPooledObjectFactory<K,V> keyedFactory)
Returns a synchronized (thread-safe) KeyedPooledObjectFactory backed by
the specified KeyedPoolableObjectFactory.
|
static <K,V> KeyedObjectPool<K,V> |
synchronizedPool(KeyedObjectPool<K,V> keyedPool)
Returns a synchronized (thread-safe) KeyedObjectPool backed by the
specified KeyedObjectPool.
|
static <T> ObjectPool<T> |
synchronizedPool(ObjectPool<T> pool)
Returns a synchronized (thread-safe) ObjectPool backed by the specified
ObjectPool.
|
static <T> PooledObjectFactory<T> |
synchronizedPooledFactory(PooledObjectFactory<T> factory)
Returns a synchronized (thread-safe) PooledObjectFactory backed by the
specified PooledObjectFactory.
|
public PoolUtils()
public static void checkRethrow(java.lang.Throwable t)
t
- The Throwable to checkjava.lang.ThreadDeath
- if that is passed injava.lang.VirtualMachineError
- if that is passed inpublic static <T> java.util.TimerTask checkMinIdle(ObjectPool<T> pool, int minIdle, long period) throws java.lang.IllegalArgumentException
ObjectPool.addObject()
then no more checks will be performed.T
- the type of objects in the poolpool
- the pool to check periodically.minIdle
- if the ObjectPool.getNumIdle()
is less than this then
add an idle object.period
- the frequency to check the number of idle objects in a pool,
see Timer.schedule(TimerTask, long, long)
.TimerTask
that will periodically check the pools idle
object count.java.lang.IllegalArgumentException
- when pool
is null
or when
minIdle
is negative or when period
isn't valid for Timer.schedule(TimerTask, long, long)
public static <K,V> java.util.TimerTask checkMinIdle(KeyedObjectPool<K,V> keyedPool, K key, int minIdle, long period) throws java.lang.IllegalArgumentException
KeyedObjectPool.addObject(Object)
then no more
checks for that key will be performed.K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the keyedPool to check periodically.key
- the key to check the idle count of.minIdle
- if the KeyedObjectPool.getNumIdle(Object)
is less than
this then add an idle object.period
- the frequency to check the number of idle objects in a
keyedPool, see Timer.schedule(TimerTask, long, long)
.TimerTask
that will periodically check the pools idle
object count.java.lang.IllegalArgumentException
- when keyedPool
, key
is
null
or when minIdle
is negative or
when period
isn't valid for
Timer.schedule(TimerTask, long, long)
.public static <K,V> java.util.Map<K,java.util.TimerTask> checkMinIdle(KeyedObjectPool<K,V> keyedPool, java.util.Collection<K> keys, int minIdle, long period) throws java.lang.IllegalArgumentException
Collection
keys
in the keyedPool. At most one
idle object will be added per period.K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the keyedPool to check periodically.keys
- a collection of keys to check the idle object count.minIdle
- if the KeyedObjectPool.getNumIdle(Object)
is less than
this then add an idle object.period
- the frequency to check the number of idle objects in a
keyedPool, see Timer.schedule(TimerTask, long, long)
.Map
of key and TimerTask
pairs that will
periodically check the pools idle object count.java.lang.IllegalArgumentException
- when keyedPool
, keys
, or any of the
values in the collection is null
or when
minIdle
is negative or when period
isn't valid for Timer.schedule(TimerTask, long, long)
.checkMinIdle(KeyedObjectPool, Object, int, long)
public static <T> void prefill(ObjectPool<T> pool, int count) throws java.lang.Exception, java.lang.IllegalArgumentException
T
- the type of objects in the poolpool
- the pool to prefill.count
- the number of idle objects to add.java.lang.Exception
- when ObjectPool.addObject()
fails.java.lang.IllegalArgumentException
- when pool
is null
.public static <K,V> void prefill(KeyedObjectPool<K,V> keyedPool, K key, int count) throws java.lang.Exception, java.lang.IllegalArgumentException
K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the keyedPool to prefill.key
- the key to add objects for.count
- the number of idle objects to add for key
.java.lang.Exception
- when KeyedObjectPool.addObject(Object)
fails.java.lang.IllegalArgumentException
- when keyedPool
or key
is
null
.public static <K,V> void prefill(KeyedObjectPool<K,V> keyedPool, java.util.Collection<K> keys, int count) throws java.lang.Exception, java.lang.IllegalArgumentException
KeyedObjectPool.addObject(Object)
on keyedPool
with each
key in keys
for count
number of times. This has
the same effect as calling prefill(KeyedObjectPool, Object, int)
for each key in the keys
collection.K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the keyedPool to prefill.keys
- Collection
of keys to add objects for.count
- the number of idle objects to add for each key
.java.lang.Exception
- when KeyedObjectPool.addObject(Object)
fails.java.lang.IllegalArgumentException
- when keyedPool
, keys
, or any value
in keys
is null
.prefill(KeyedObjectPool, Object, int)
public static <T> ObjectPool<T> synchronizedPool(ObjectPool<T> pool)
Note: This should not be used on pool implementations that already
provide proper synchronization such as the pools provided in the Commons
Pool library. Wrapping a pool that waits
for poolable
objects to be returned before allowing another one to be borrowed with
another layer of synchronization will cause liveliness issues or a
deadlock.
T
- the type of objects in the poolpool
- the ObjectPool to be "wrapped" in a synchronized ObjectPool.public static <K,V> KeyedObjectPool<K,V> synchronizedPool(KeyedObjectPool<K,V> keyedPool)
Note: This should not be used on pool implementations that already
provide proper synchronization such as the pools provided in the Commons
Pool library. Wrapping a pool that waits
for poolable
objects to be returned before allowing another one to be borrowed with
another layer of synchronization will cause liveliness issues or a
deadlock.
K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the KeyedObjectPool to be "wrapped" in a synchronized
KeyedObjectPool.public static <T> PooledObjectFactory<T> synchronizedPooledFactory(PooledObjectFactory<T> factory)
T
- the type of objects in the poolfactory
- the PooledObjectFactory to be "wrapped" in a synchronized
PooledObjectFactory.public static <K,V> KeyedPooledObjectFactory<K,V> synchronizedKeyedPooledFactory(KeyedPooledObjectFactory<K,V> keyedFactory)
K
- the type of the pool keyV
- the type of pool entrieskeyedFactory
- the KeyedPooledObjectFactory to be "wrapped" in a
synchronized KeyedPooledObjectFactory.public static <T> ObjectPool<T> erodingPool(ObjectPool<T> pool)
T
- the type of objects in the poolpool
- the ObjectPool to be decorated so it shrinks its idle count
when possible.erodingPool(ObjectPool, float)
public static <T> ObjectPool<T> erodingPool(ObjectPool<T> pool, float factor)
The factor parameter provides a mechanism to tweak the rate at which the pool tries to shrink its size. Values between 0 and 1 cause the pool to try to shrink its size more often. Values greater than 1 cause the pool to less frequently try to shrink its size.
T
- the type of objects in the poolpool
- the ObjectPool to be decorated so it shrinks its idle count
when possible.factor
- a positive value to scale the rate at which the pool tries to
reduce its size. If 0 < factor < 1 then the pool
shrinks more aggressively. If 1 < factor then the pool
shrinks less aggressively.erodingPool(ObjectPool)
public static <K,V> KeyedObjectPool<K,V> erodingPool(KeyedObjectPool<K,V> keyedPool)
K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the KeyedObjectPool to be decorated so it shrinks its idle
count when possible.erodingPool(KeyedObjectPool, float)
,
erodingPool(KeyedObjectPool, float, boolean)
public static <K,V> KeyedObjectPool<K,V> erodingPool(KeyedObjectPool<K,V> keyedPool, float factor)
The factor parameter provides a mechanism to tweak the rate at which the pool tries to shrink its size. Values between 0 and 1 cause the pool to try to shrink its size more often. Values greater than 1 cause the pool to less frequently try to shrink its size.
K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the KeyedObjectPool to be decorated so it shrinks its idle
count when possible.factor
- a positive value to scale the rate at which the pool tries to
reduce its size. If 0 < factor < 1 then the pool
shrinks more aggressively. If 1 < factor then the pool
shrinks less aggressively.erodingPool(KeyedObjectPool, float, boolean)
public static <K,V> KeyedObjectPool<K,V> erodingPool(KeyedObjectPool<K,V> keyedPool, float factor, boolean perKey)
The factor parameter provides a mechanism to tweak the rate at which the pool tries to shrink its size. Values between 0 and 1 cause the pool to try to shrink its size more often. Values greater than 1 cause the pool to less frequently try to shrink its size.
The perKey parameter determines if the pool shrinks on a whole pool basis or a per key basis. When perKey is false, the keys do not have an effect on the rate at which the pool tries to shrink its size. When perKey is true, each key is shrunk independently.
K
- the type of the pool keyV
- the type of pool entrieskeyedPool
- the KeyedObjectPool to be decorated so it shrinks its idle
count when possible.factor
- a positive value to scale the rate at which the pool tries to
reduce its size. If 0 < factor < 1 then the pool
shrinks more aggressively. If 1 < factor then the pool
shrinks less aggressively.perKey
- when true, each key is treated independently.erodingPool(KeyedObjectPool)
,
erodingPool(KeyedObjectPool, float)
Copyright © 2000-2018 Apache Software Foundation. All Rights Reserved.