com.bonzaiengine.threading

Class TaskQueue<T>

java.lang.Object

com.bonzaiengine.threading.TaskQueue<T>

All Implemented Interfaces:

Task.StateChangeListener<T>

public class TaskQueue<T>
extends java.lang.Object
implements Task.StateChangeListener<T>

Constructor Summary

Constructors

Constructor and Description
TaskQueue()

Method Summary

Modifier and Type	Method and Description
int	getNumTasks()
boolean	isComputing()
void	onStateChange(Task<T> task, Task.TaskState state)
void	queue(Task<T> task, IWorker worker)
void	waitQueueEmpty() Block until all Task has been processed/complete

Methods inherited from class java.lang.Object

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

Constructor Detail

TaskQueue

public TaskQueue()

Method Detail

queue

public final void queue(Task<T> task,
                        IWorker worker)

Parameters:

task - a Task

worker - an IWorker to queue the task in, null if already queued

waitQueueEmpty

public final void waitQueueEmpty()

Block until all Task has been processed/complete

isComputing

public final boolean isComputing()

Returns:

true if the queue is not empty

getNumTasks

public final int getNumTasks()

Returns:

the number of tasks active

onStateChange

public final void onStateChange(Task<T> task,
                                Task.TaskState state)

Specified by:

onStateChange in interface Task.StateChangeListener<T>