程序包 org.tio.utils.thread.pool

类 AbstractQueueRunnable<T>

java.lang.Object

org.tio.utils.thread.pool.AbstractSynRunnable

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

所有已实现的接口:

Runnable

public abstract class AbstractQueueRunnable<T>
extends AbstractSynRunnable

作者:

tanyaowu 2017年4月4日 上午9:23:12

字段概要

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

executed, executor, runningLock

构造器概要

构造器

构造器	说明
AbstractQueueRunnable(Executor executor)

方法概要

修饰符和类型	方法	说明
boolean	addMsg(T t)
void	clearMsgQueue()	清空处理的队列消息
abstract FullWaitQueue<T>	getMsgQueue()	获取消息队列
boolean	isNeededExecute()

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

execute, isCanceled, logstr, run, runTask, setCanceled

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

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

构造器详细资料

AbstractQueueRunnable

public AbstractQueueRunnable(Executor executor)

方法详细资料

addMsg

public boolean addMsg(T t)

返回:

clearMsgQueue

public void clearMsgQueue()

清空处理的队列消息

isNeededExecute

public boolean isNeededExecute()

指定者:

isNeededExecute 在类中 AbstractSynRunnable

getMsgQueue

public abstract FullWaitQueue<T> getMsgQueue()

获取消息队列

返回: