org.jim.server.command.handler.processor.chat

Class MsgQueueRunnable

java.lang.Object

org.tio.utils.thread.pool.AbstractSynRunnable

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

org.jim.server.command.handler.processor.chat.MsgQueueRunnable

All Implemented Interfaces:

Runnable, org.tio.utils.thread.pool.ISynRunnable

public class MsgQueueRunnable
extends org.tio.utils.thread.pool.AbstractQueueRunnable<ImPacket>

Author:

WChao

Field Summary

Fields inherited from class org.tio.utils.thread.pool.AbstractQueueRunnable

msgQueue

Constructor Summary

Constructors

Constructor and Description
MsgQueueRunnable(org.tio.core.ChannelContext channelContext, Executor executor)

Method Summary

Modifier and Type	Method and Description
boolean	addMsg(ImPacket msg)
void	runTask()

Methods inherited from class org.tio.utils.thread.pool.AbstractQueueRunnable

clearMsgQueue, isNeededExecute

Methods inherited from class org.tio.utils.thread.pool.AbstractSynRunnable

getExecutor, isCanceled, run, runningLock, setCanceled, setExecutor

Methods inherited from class java.lang.Object

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

Constructor Detail

MsgQueueRunnable

public MsgQueueRunnable(org.tio.core.ChannelContext channelContext,
                        Executor executor)

Method Detail

addMsg

public boolean addMsg(ImPacket msg)

Overrides:

addMsg in class org.tio.utils.thread.pool.AbstractQueueRunnable<ImPacket>

runTask

public void runTask()