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

构造器概要

构造器

限定符	构造器和说明
protected	AbstractQueueRunnable(Executor executor)

方法概要

限定符和类型	方法和说明
boolean	addMsg(T t) addMsg
void	clearMsgQueue() 清空处理的队列消息
abstract Queue<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

protected AbstractQueueRunnable(Executor executor)

方法详细资料

addMsg

public boolean addMsg(T t)

addMsg

参数:

t - message

返回:

是否成功

clearMsgQueue

public void clearMsgQueue()

清空处理的队列消息

isNeededExecute

public boolean isNeededExecute()

指定者:

isNeededExecute 在类中 AbstractSynRunnable

getMsgQueue

public abstract Queue<T> getMsgQueue()

获取消息队列

返回:

Queue