com.tencent.tcaplus.util

Class ObjectPool<T>

java.lang.Object

com.tencent.tcaplus.util.ObjectPool<T>

Direct Known Subclasses:

MessageBufferPool

public abstract class ObjectPool<T>
extends Object

使用数组方式实现的对象池泛型抽象类，对象池有固定最大容量。初始化时没有分配对象，只在空闲对象为空时才分配新的对象。 最多只分配最大容量个对象，用户使用完对象后需要及时归还。

Version:

version 1.0

Author:

yahuiwang

Field Summary

Fields

Modifier and Type	Field and Description
protected int	allocateCount
protected int	capacity
protected BlockingQueue<T>	queue

Constructor Summary

Constructors

Constructor and Description
ObjectPool(int capacity) 构造函数，初始化最大容量

Method Summary

Modifier and Type	Method and Description
protected abstract T	allocate() 子类重载该方法，返回一个具化类对象
int	allocateCount()
void	drainTo(Collection<? super T> c, int maxElements)
boolean	offer(T obj) 将指定的元素插入到此队列的尾部（如果立即可行且不会超过该队列的容量），
protected T	poll() 获取并移除此队列的头，如果此队列为空且有未分配空间则分配一个对象，否则返回 null
T	take() 获取并移除此队列的头部，在元素变得可用之前一直等待（如果有必要）
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

allocateCount

protected int allocateCount

capacity

protected int capacity

queue

protected BlockingQueue<T> queue

Constructor Detail

ObjectPool

public ObjectPool(int capacity)

构造函数，初始化最大容量

Parameters:

capacity - 对象池最大容量

Method Detail

take

public T take()

获取并移除此队列的头部，在元素变得可用之前一直等待（如果有必要）

Returns:

返回对象

drainTo

public void drainTo(Collection<? super T> c,
                    int maxElements)

poll

protected T poll()

获取并移除此队列的头，如果此队列为空且有未分配空间则分配一个对象，否则返回 null

Returns:

返回对象

offer

public boolean offer(T obj)

将指定的元素插入到此队列的尾部（如果立即可行且不会超过该队列的容量），

在成功时返回 true，如果此队列已满，则返回 false。

allocate

protected abstract T allocate()

子类重载该方法，返回一个具化类对象

Returns:

返回具化类对象

toString

public String toString()

Overrides:

toString in class Object

allocateCount

public int allocateCount()