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
void	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 void addTask(SimpleTaskQueueDTO task)

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()