org.darkphoenixs.pool

类 PoolBase<T>

java.lang.Object

org.darkphoenixs.pool.PoolBase<T>

所有已实现的接口:

Closeable, Serializable, AutoCloseable

直接已知子类:

HbaseConnectionPool, JdbcConnectionPool, KafkaConnectionPool, RedisConnectionPoolOld, RedisSentinelConnPoolOld, RedisShardedConnPoolOld, SocketConnectionPool

public abstract class PoolBase<T>
extends Object
implements Closeable, Serializable

Title: PoolBase

Description: 池基类

从以下版本开始:

2015年9月19日

版本:

1.0

作者:

Victor

另请参阅:

Closeable, Serializable, 序列化表格

字段概要

字段

限定符和类型	字段和说明
protected GenericObjectPool<T>	internalPool internalPool
private static long	serialVersionUID serialVersionUID

构造器概要

构造器

构造器和说明
PoolBase() Title: ConnectionPoolBase Description: 构造方法
PoolBase(GenericObjectPoolConfig poolConfig, PooledObjectFactory<T> factory) Title: ConnectionPoolBase Description: 构造方法

方法概要

方法

限定符和类型	方法和说明
protected void	addObjects(int count) Title: addObjects Description: 添加池对象
void	clear() Title: clear Description: 清除对象池
void	close() Title: close Description: 关闭对象池
protected void	destroy() Title: destroy Description: 销毁对象池
long	getMaxBorrowWaitTimeMillis() Title: getMaxBorrowWaitTimeMillis Description: 获得最大等待时间
long	getMeanBorrowWaitTimeMillis() Title: getMeanBorrowWaitTimeMillis Description: 获得平均等待时间
int	getNumActive() Title: getNumActive Description: 获得池激活数
int	getNumIdle() Title: getNumIdle Description: 获得池空闲数
int	getNumWaiters() Title: getNumWaiters Description: 获得池等待数
protected T	getResource() Title: getResource Description: 获得池对象
protected void	initPool(GenericObjectPoolConfig poolConfig, PooledObjectFactory<T> factory) Title: initPool Description: 初始化对象池
protected void	invalidateResource(T resource) Title: invalidateResource Description: 废弃池对象
boolean	isClosed() Title: isClosed Description: 池是否关闭
private boolean	isInactived() Title: isInactived Description: 池是否失效
protected void	returnResource(T resource) Title: returnResource Description: 返回池对象

从类继承的方法 java.lang.Object

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

字段详细资料

serialVersionUID

private static final long serialVersionUID

serialVersionUID

另请参阅:

常量字段值

internalPool

protected GenericObjectPool<T> internalPool

internalPool

构造器详细资料

PoolBase

public PoolBase()

Title: ConnectionPoolBase

Description: 构造方法

PoolBase

public PoolBase(GenericObjectPoolConfig poolConfig,
        PooledObjectFactory<T> factory)

Title: ConnectionPoolBase

Description: 构造方法

参数:

poolConfig - 池配置

factory - 池对象工厂

方法详细资料

initPool

protected void initPool(GenericObjectPoolConfig poolConfig,
            PooledObjectFactory<T> factory)

Title: initPool

Description: 初始化对象池

参数:

poolConfig - 池配置

factory - 池对象工厂

destroy

protected void destroy()

Title: destroy

Description: 销毁对象池

getResource

protected T getResource()

Title: getResource

Description: 获得池对象

返回:

池对象

returnResource

protected void returnResource(T resource)

Title: returnResource

Description: 返回池对象

参数:

resource - 池对象

invalidateResource

protected void invalidateResource(T resource)

Title: invalidateResource

Description: 废弃池对象

参数:

resource - 池对象

getNumActive

public int getNumActive()

Title: getNumActive

Description: 获得池激活数

返回:

激活数

getNumIdle

public int getNumIdle()

Title: getNumIdle

Description: 获得池空闲数

返回:

空闲数

getNumWaiters

public int getNumWaiters()

Title: getNumWaiters

Description: 获得池等待数

返回:

等待数

getMeanBorrowWaitTimeMillis

public long getMeanBorrowWaitTimeMillis()

Title: getMeanBorrowWaitTimeMillis

Description: 获得平均等待时间

返回:

平均等待时间

getMaxBorrowWaitTimeMillis

public long getMaxBorrowWaitTimeMillis()

Title: getMaxBorrowWaitTimeMillis

Description: 获得最大等待时间

返回:

最大等待时间

isClosed

public boolean isClosed()

Title: isClosed

Description: 池是否关闭

返回:

是否关闭

isInactived

private boolean isInactived()

Title: isInactived

Description: 池是否失效

返回:

是否失效

addObjects

protected void addObjects(int count)

Title: addObjects

Description: 添加池对象

参数:

count - 池对象数量

clear

public void clear()

Title: clear

Description: 清除对象池

close

public void close()

Title: close

Description: 关闭对象池

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable