org.tio.core.task

类 DecodeRunnable

java.lang.Object

org.tio.utils.thread.pool.AbstractSynRunnable

org.tio.utils.thread.pool.AbstractQueueRunnable<ByteBuffer>

org.tio.core.task.DecodeRunnable

所有已实现的接口:

Runnable

public class DecodeRunnable
extends AbstractQueueRunnable<ByteBuffer>

解码任务对象，一个连接对应一个本对象

作者:

谭耀武 2012-08-09

字段概要

从类继承的字段 org.tio.utils.thread.pool.AbstractQueueRunnable

msgQueue

从类继承的字段 org.tio.utils.thread.pool.AbstractSynRunnable

avoidRepeatExecuteCount, executeCount, executor, loopCount, runCount

构造器概要

构造器

构造器和说明
DecodeRunnable(ChannelContext channelContext, Executor executor)

方法概要

限定符和类型	方法和说明
void	clearMsgQueue() 清空处理的队列消息
void	decode()
void	handler(Packet packet, int byteCount)
String	logstr()
void	runTask()
void	setNewByteBuffer(ByteBuffer newByteBuffer)
String	toString()

从类继承的方法 org.tio.utils.thread.pool.AbstractQueueRunnable

addMsg, isNeededExecute

从类继承的方法 org.tio.utils.thread.pool.AbstractSynRunnable

execute, isCanceled, isExecuted, run, runningLock, setCanceled, setExecuted

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

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

构造器详细资料

DecodeRunnable

public DecodeRunnable(ChannelContext channelContext,
                      Executor executor)

方法详细资料

handler

public void handler(Packet packet,
                    int byteCount)

参数:

packet -

byteCount -

clearMsgQueue

public void clearMsgQueue()

清空处理的队列消息

覆盖:

clearMsgQueue 在类中 AbstractQueueRunnable<ByteBuffer>

runTask

public void runTask()

指定者:

runTask 在类中 AbstractSynRunnable

decode

public void decode()

另请参阅:

Runnable.run()

setNewByteBuffer

public void setNewByteBuffer(ByteBuffer newByteBuffer)

参数:

newByteBuffer - the newByteBuffer to set

toString

public String toString()

覆盖:

toString 在类中 Object

logstr

public String logstr()

覆盖:

logstr 在类中 AbstractSynRunnable