org.eclipse.scada.utils.concurrent

Class IteratingFuture<T,S>

java.lang.Object

org.eclipse.scada.utils.concurrent.AbstractFuture<T>

org.eclipse.scada.utils.concurrent.IteratingFuture<T,S>

Type Parameters:

T - the type of the future

S - the type of the list

All Implemented Interfaces:

Future<T>, NotifyFuture<T>

Direct Known Subclasses:

AuthorizationHelper.IteratingAuthorizer

public abstract class IteratingFuture<T,S>
extends AbstractFuture<T>

Since:

1.1

Author:

Jens Reimann

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	IteratingFuture.FutureListenerImpl

Constructor Summary

Constructors

Constructor and Description
IteratingFuture(Iterable<? extends S> iterable)

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
protected void	doComplete(Future<T> future, S current)
protected abstract void	handleComplete(Future<T> future, S current)
protected abstract NotifyFuture<T>	last()
protected abstract NotifyFuture<T>	perform(S s)
protected void	processCurrent()
protected void	processNext()
IteratingFuture<T,S>	startIterating() Start iterating over the list

Methods inherited from class org.eclipse.scada.utils.concurrent.AbstractFuture

addListener, addListener, fetchResult, get, get, isCancelled, isDone, removeListener, removeListener, setError, setResult

Methods inherited from class java.lang.Object

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

Constructor Detail

IteratingFuture

public IteratingFuture(Iterable<? extends S> iterable)

Method Detail

startIterating

public IteratingFuture<T,S> startIterating()

Start iterating over the list

Returns:

this instance

processCurrent

protected void processCurrent()

processNext

protected void processNext()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

Overrides:

cancel in class AbstractFuture<T>

doComplete

protected void doComplete(Future<T> future,
                          S current)
                   throws Exception

Throws:

Exception

handleComplete

protected abstract void handleComplete(Future<T> future,
                                       S current)
                                throws Exception

Throws:

Exception

perform

protected abstract NotifyFuture<T> perform(S s)

last

protected abstract NotifyFuture<T> last()