com.tencent.tcaplus.message.impl

Class MessageBufferPool

java.lang.Object

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

com.tencent.tcaplus.message.impl.MessageBufferPool

public class MessageBufferPool
extends ObjectPool<MessageBuffer>

Field Summary

Fields

Modifier and Type	Field and Description
ObjectPool<byte[]>	byteArrayPool

Fields inherited from class com.tencent.tcaplus.util.ObjectPool

allocateCount, capacity, queue

Constructor Summary

Constructors

Constructor and Description
MessageBufferPool(int capaticy, int memSize, int packBufferSize)

Method Summary

Modifier and Type	Method and Description
protected MessageBufferImpl	allocate() 子类重载该方法，返回一个具化类对象
static MessageBufferPool	create()
com.tencent.tcaplus.message.impl.ByteBufferPool	getByteBufferPool()
boolean	offer(MessageBuffer messageBuffer) 将指定的元素插入到此队列的尾部（如果立即可行且不会超过该队列的容量），
MessageBuffer	packMsgBuffer(TCapdirCSPkg pkg)
MessageBuffer	packMsgBuffer(TCaplusPkg pkg)

Methods inherited from class com.tencent.tcaplus.util.ObjectPool

allocateCount, drainTo, poll, take, toString

Methods inherited from class java.lang.Object

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

Field Detail

byteArrayPool

public ObjectPool<byte[]> byteArrayPool

Constructor Detail

MessageBufferPool

public MessageBufferPool(int capaticy,
                         int memSize,
                         int packBufferSize)

Parameters:

capaticy - MessageBuffer数量

memSize - MessageBuffer共享的内存块总容量

packBufferSize - MessageBuffer TDR消息打包缓冲区大小

Method Detail

allocate

protected MessageBufferImpl allocate()

Description copied from class: ObjectPool

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

Specified by:

allocate in class ObjectPool<MessageBuffer>

Returns:

返回具化类对象

offer

public boolean offer(MessageBuffer messageBuffer)

Description copied from class: ObjectPool

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

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

Overrides:

offer in class ObjectPool<MessageBuffer>

getByteBufferPool

public com.tencent.tcaplus.message.impl.ByteBufferPool getByteBufferPool()

packMsgBuffer

public MessageBuffer packMsgBuffer(TCaplusPkg pkg)
                            throws TdrException

Throws:

TdrException

packMsgBuffer

public MessageBuffer packMsgBuffer(TCapdirCSPkg pkg)
                            throws TdrException

Throws:

TdrException

create

public static MessageBufferPool create()