com.bonzaiengine.threading

Class WorkerQueue

java.lang.Object

com.bonzaiengine.threading.WorkerQueue

All Implemented Interfaces:

IWorker

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

IWorker implementation using a single thread.

Constructor Summary

Constructors

Constructor and Description
WorkerQueue()
WorkerQueue(java.lang.String name)
WorkerQueue(java.lang.String name, int priority)

Method Summary

Modifier and Type	Method and Description
protected void	finalize()
int	getQueueSize()
protected void	internalRun()
boolean	isQueueEmpty()
void	pause(boolean pause)
boolean	queueWithoutDependencies(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

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

Methods inherited from interface com.bonzaiengine.threading.IWorker

isWorking, queue

Constructor Detail

WorkerQueue

public WorkerQueue()

WorkerQueue

public WorkerQueue(java.lang.String name)

WorkerQueue

public WorkerQueue(java.lang.String name,
                   int priority)

Method Detail

queueWithoutDependencies

public boolean queueWithoutDependencies(Task<?> task)

Description copied from interface: IWorker

Queue a task and process it asynchroneously

Specified by:

queueWithoutDependencies 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

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

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable

internalRun

protected void internalRun()