com.bonzaiengine.threading

Interface IWorker

All Known Implementing Classes:

WorkerDispatcher, WorkerQueue

public interface IWorker

See Also:

WorkerQueue, WorkerDispatcher

Method Summary

Modifier and Type	Method and Description
int	getQueueSize()
boolean	isQueueEmpty()
boolean	isWorking()
void	pause(boolean pause)
boolean	queue(Task<?> task) Queue a task and process it asynchroneously
void	stop() Stop the processing of the Task
void	waitQueueEmpty() Wait the queue is empty and all task has finish, and return

Method Detail

queue

boolean queue(Task<?> task)

Queue a task and process it asynchroneously

Returns:

true if added in the queue (ie not already queued)

Throws:

java.lang.IllegalArgumentException - if the Task is already computing

{@link - IllegalStateException} if the IWorker is not running

getQueueSize

int getQueueSize()

Returns:

the number of task queued

isQueueEmpty

boolean isQueueEmpty()

Returns:

true if all task has been processed

isWorking

boolean isWorking()

Returns:

true if a task is processing or the queue is not empty.

waitQueueEmpty

void waitQueueEmpty()

Wait the queue is empty and all task has finish, and return

pause

void pause(boolean pause)

Parameters:

pause - pause the processing of the Task

stop

void stop()

Stop the processing of the Task