xyz.noark.core.thread

类 TaskQueue

java.lang.Object

xyz.noark.core.thread.TaskQueue

直接已知子类:

MonitorTaskQueue

public class TaskQueue
extends java.lang.Object

任务处理队列.

从以下版本开始:

3.0

作者:

小流氓[176543888@qq.com]

构造器概要

构造器

构造器和说明
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

构造器详细资料

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 - 异步任务