org.egothor.distributor

Class STE<T>

java.lang.Object

org.egothor.distributor.STE<T>

All Implemented Interfaces:

Distributor<T>

Direct Known Subclasses:

MTE

public class STE<T>
extends Object
implements Distributor<T>

An STE distributes all jobs sequentially, that is, the recipients of jobs are always iterated one by one.

Author:

Leo Galambos

Constructor Summary

Constructors

Constructor and Description
STE()

Method Summary

Modifier and Type	Method and Description
void	allow() Restart the thread.
void	forEach(Sequence<T> to, Task<T> task) Iterate through the Enumeration and give the element the task.
void	iterate(Sequence<T> to, Request<T> task) Iterate through the Enumeration and give the element the task, if not already completed..
void	stop() Stop the thread.

Methods inherited from class java.lang.Object

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

Constructor Detail

STE

public STE()

Method Detail

forEach

public void forEach(Sequence<T> to,
                    Task<T> task)

Iterate through the Enumeration and give the element the task.

Specified by:

forEach in interface Distributor<T>

Parameters:

to - the Enumeration of recipients

task - the task

iterate

public void iterate(Sequence<T> to,
                    Request<T> task)

Iterate through the Enumeration and give the element the task, if not already completed.. If the thread is stopped the method will not execute.

Specified by:

iterate in interface Distributor<T>

Parameters:

to - the Enumeration of recipients

task - the task

stop

public void stop()

Stop the thread.

Specified by:

stop in interface Distributor<T>

allow

public void allow()

Restart the thread.

Specified by:

allow in interface Distributor<T>