Package cn.net.pap.task.queue

Class SimpleTaskQueue

java.lang.Object

cn.net.pap.task.queue.SimpleTaskQueue

public class SimpleTaskQueue
extends Object

Method Summary

Modifier and Type	Method	Description
boolean	addTask(SimpleTaskQueueDTO task)	因为限制了队列长度，所以这里增加一下返回值。
List<SimpleTaskQueueDTO>	drainUnprocessedTasks()
Thread	getConsumerThread()
static SimpleTaskQueue	getInstance()
int	getPendingTaskCount()
boolean	isRunning()
Thread	startConsumer()
List<SimpleTaskQueueDTO>	stopConsumerAndReturnUnProcessed()

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static SimpleTaskQueue getInstance()

addTask

public boolean addTask(SimpleTaskQueueDTO task)

因为限制了队列长度，所以这里增加一下返回值。

Parameters:

task -

Returns:

startConsumer

public Thread startConsumer()

stopConsumerAndReturnUnProcessed

public List<SimpleTaskQueueDTO> stopConsumerAndReturnUnProcessed()

isRunning

public boolean isRunning()

getConsumerThread

public Thread getConsumerThread()

getPendingTaskCount

public int getPendingTaskCount()

drainUnprocessedTasks

public List<SimpleTaskQueueDTO> drainUnprocessedTasks()