com.bonzaiengine.threading

Class WorkerDispatcher

java.lang.Object

com.bonzaiengine.threading.WorkerDispatcher

All Implemented Interfaces:

IWorker

public final class WorkerDispatcher
extends java.lang.Object
implements IWorker

IWorker implementation using multiple parallel threads.

Constructor Summary

Constructors

Constructor and Description
WorkerDispatcher(int maxThreads)
WorkerDispatcher(int maxThreads, java.lang.String name)

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

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerDispatcher

public WorkerDispatcher(int maxThreads)

WorkerDispatcher

public WorkerDispatcher(int maxThreads,
                        java.lang.String name)

Method Detail

queue

public boolean queue(Task<?> task)

Description copied from interface: IWorker

Queue a task and process it asynchroneously

Specified by:

queue in interface IWorker

Returns:

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

getQueueSize

public int getQueueSize()

Specified by:

getQueueSize in interface IWorker

Returns:

the number of task queued

isQueueEmpty

public boolean isQueueEmpty()

Specified by:

isQueueEmpty in interface IWorker

Returns:

true if all task has been processed

isWorking

public boolean isWorking()

Specified by:

isWorking in interface IWorker

Returns:

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

waitQueueEmpty

public void waitQueueEmpty()

Description copied from interface: IWorker

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

Specified by:

waitQueueEmpty in interface IWorker

pause

public void pause(boolean pause)

Specified by:

pause in interface IWorker

Parameters:

pause - pause the processing of the Task

stop

public void stop()

Description copied from interface: IWorker

Stop the processing of the Task

Specified by:

stop in interface IWorker