org.aredis.util.pool

Class LeakCheckingAsyncObjectPool<E>

java.lang.Object

org.aredis.util.pool.AsyncObjectPool<E>

org.aredis.util.pool.LeakCheckingAsyncObjectPool<E>

Type Parameters:

E - Type of Member Object

public class LeakCheckingAsyncObjectPool<E>
extends AsyncObjectPool<E>

A Object Pool which prints an error log message when a object leak is detected.

Author:

Suresh

Nested Class Summary

Nested classes/interfaces inherited from class org.aredis.util.pool.AsyncObjectPool

AsyncObjectPool.PoolMemberHolder<T>

Field Summary

Fields

Modifier and Type	Field and Description
static long	DEFAULT_LEAK_LOG_INTERVAL Default leak log interval in milliseconds.
static long	DEFAULT_MAX_HOLD_TIME_MILLIS DEFAULT hold time in milliseconds.
protected long	leakLogIntervalMillis Leak log interval.
protected long	maxHoldTimeMillis Max hold time.

Fields inherited from class org.aredis.util.pool.AsyncObjectPool

reconcileCount

Constructor Summary

Constructors

Constructor and Description
LeakCheckingAsyncObjectPool(AsyncPoolMemberManager<E> pobjectManager, int ppoolSize, Executor ptaskExecutor) Creates a Leak checking AsyncObject Pool with default parameters for max hold time and log intervals.

Method Summary

Methods

Modifier and Type	Method and Description
long	getLeakLogIntervalMillis() Gets the leak log interval.
long	getMaxHoldTimeMillis() Gets max hold time.
void	setLeakLogIntervalMillis(long pleakLogIntervalMillis) Sets the leak log interval.
void	setMaxHoldTimeMillis(long pmaxHoldTimeMillis) Sets the max hold time.

Methods inherited from class org.aredis.util.pool.AsyncObjectPool

asyncBorrow, borrow, getPoolSize, memberIterator, printStatus, returnToPool, setPoolSize, syncBorrow

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_MAX_HOLD_TIME_MILLIS

public static long DEFAULT_MAX_HOLD_TIME_MILLIS

DEFAULT hold time in milliseconds.

DEFAULT_LEAK_LOG_INTERVAL

public static long DEFAULT_LEAK_LOG_INTERVAL

Default leak log interval in milliseconds.

maxHoldTimeMillis

protected long maxHoldTimeMillis

Max hold time.

leakLogIntervalMillis

protected long leakLogIntervalMillis

Leak log interval.

Constructor Detail

LeakCheckingAsyncObjectPool

public LeakCheckingAsyncObjectPool(AsyncPoolMemberManager<E> pobjectManager,
                           int ppoolSize,
                           Executor ptaskExecutor)

Creates a Leak checking AsyncObject Pool with default parameters for max hold time and log intervals.

Parameters:

pobjectManager - Object Manager to Create and Destroy Pool member objects

ppoolSize - Pool Size

ptaskExecutor - Executor to use. Mandatory in case of async usage, not needed otherwise

Method Detail

getMaxHoldTimeMillis

public long getMaxHoldTimeMillis()

Gets max hold time.

Returns:

Max hold time

setMaxHoldTimeMillis

public void setMaxHoldTimeMillis(long pmaxHoldTimeMillis)

Sets the max hold time. If a borrowed object is not returned within this time an error message is printed.

Parameters:

pmaxHoldTimeMillis - Max Hold Time

getLeakLogIntervalMillis

public long getLeakLogIntervalMillis()

Gets the leak log interval.

Returns:

Leak log interval

setLeakLogIntervalMillis

public void setLeakLogIntervalMillis(long pleakLogIntervalMillis)

Sets the leak log interval. This is the interval in which successive Log messages are printed for this pool.

Parameters:

pleakLogIntervalMillis - Leak Log interval