foxtrot.workers

Class MultiWorkerThread

java.lang.Object

foxtrot.AbstractWorkerThread

foxtrot.workers.SingleWorkerThread

foxtrot.workers.MultiWorkerThread

All Implemented Interfaces:

WorkerThread, java.lang.Runnable

public class MultiWorkerThread
extends SingleWorkerThread

Full implementation of WorkerThread that uses one or more threads to run Tasks subclasses.
Tasks execution is parallelized: two tasks posted at the same time are executed in parallel by two different threads. This is done by using a mechanism similar to a classic web server threading: one thread waits for incoming tasks and a new thread is spawned to run the task. This ensures that the SingleWorkerThread.postTask(foxtrot.Task) method returns immediately in any case.

Version:

$Revision: 1.2 $

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.List	runners

Fields inherited from class foxtrot.workers.SingleWorkerThread

debug

Constructor Summary

Constructors

Constructor and Description
MultiWorkerThread()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.lang.String	getThreadName() Returns the name of the worker thread used by this WorkerThread.
(package private) boolean	hasPendingTasks()
boolean	isWorkerThread() Returns whether the current thread is a thread used by the implementation of this WorkerThread to run Tasks.
protected void	run(Task task) Executes the given Task.

Methods inherited from class foxtrot.workers.SingleWorkerThread

isAlive, isThreadInterrupted, nextSequence, postTask, run, start, stop, takeTask

Methods inherited from class foxtrot.AbstractWorkerThread

runTask

Methods inherited from class java.lang.Object

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

Field Detail

runners

private final java.util.List runners

Constructor Detail

MultiWorkerThread

public MultiWorkerThread()

Method Detail

getThreadName

protected java.lang.String getThreadName()

Description copied from class: SingleWorkerThread

Returns the name of the worker thread used by this WorkerThread.

Overrides:

getThreadName in class SingleWorkerThread

run

protected void run(Task task)

Description copied from class: SingleWorkerThread

Executes the given Task. This implementation will just call AbstractWorkerThread.runTask(foxtrot.Task).

Overrides:

run in class SingleWorkerThread

isWorkerThread

public boolean isWorkerThread()

Description copied from interface: WorkerThread

Returns whether the current thread is a thread used by the implementation of this WorkerThread to run Tasks.

Specified by:

isWorkerThread in interface WorkerThread

Overrides:

isWorkerThread in class SingleWorkerThread

hasPendingTasks

boolean hasPendingTasks()

Overrides:

hasPendingTasks in class SingleWorkerThread