xyz.noark.core.thread.task

类 TaskQueue

java.lang.Object

xyz.noark.core.thread.task.TaskQueue

直接已知子类:

MonitorTaskQueue

public class TaskQueue
extends java.lang.Object

任务处理队列.

从以下版本开始:

3.0

作者:

小流氓[176543888@qq.com]

字段概要

字段

限定符和类型	字段和说明
static java.lang.String	QUEUE_ID 队列ID = queueId

构造器概要

构造器

构造器和说明
TaskQueue(java.io.Serializable id, java.util.concurrent.ExecutorService threadPool)

方法概要

限定符和类型	方法和说明
void	complete() 完成一个任务后续处理
protected void	exec(AsyncQueueTask task) 执行异步任务.
java.io.Serializable	getId() 获取任务队列ID
protected java.util.concurrent.ExecutorService	getThreadPool() 获取执行业务线程池
void	submit(AsyncQueueTask task) 往任务队列里提交一个任务。

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

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

字段详细资料

QUEUE_ID

public static final java.lang.String QUEUE_ID

队列ID = queueId

另请参阅:

常量字段值

构造器详细资料

TaskQueue

public TaskQueue(java.io.Serializable id,
                 java.util.concurrent.ExecutorService threadPool)

方法详细资料

getId

public java.io.Serializable getId()

获取任务队列ID

返回:

队列ID

submit

public void submit(AsyncQueueTask task)

往任务队列里提交一个任务。

参数:

task - 任务

complete

public void complete()

完成一个任务后续处理

getThreadPool

protected java.util.concurrent.ExecutorService getThreadPool()

获取执行业务线程池

返回:

执行业务线程池

exec

protected void exec(AsyncQueueTask task)

执行异步任务.

就是把任务提交到线程池中

参数:

task - 异步任务