eu.toolchain.concurrent

Class DelayedCollectCoordinator<S,T>

java.lang.Object

eu.toolchain.concurrent.DelayedCollectCoordinator<S,T>

Type Parameters:

S - The source type being collected.

T - The target type the source type is being collected into.

All Implemented Interfaces:

Handle<S>, Runnable

public class DelayedCollectCoordinator<S,T>
extends Object
implements Handle<S>, Runnable

Coordinator thread for handling delayed callables executing with a given parallelism.

Constructor Summary

Constructors

Constructor and Description
DelayedCollectCoordinator(Caller caller, Collection<? extends Callable<? extends Stage<? extends S>>> callables, Consumer<S> consumer, Supplier<T> supplier, Completable<? super T> future, int parallelism)

Method Summary

Modifier and Type	Method and Description
void	cancelled() Handle to be called when the underlying stage is cancelled.
void	completed(S result) Handle to be called when the underlying stage is completed.
void	failed(Throwable cause) Handle to be called when the underlying stage is failed.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

DelayedCollectCoordinator

public DelayedCollectCoordinator(Caller caller,
                                 Collection<? extends Callable<? extends Stage<? extends S>>> callables,
                                 Consumer<S> consumer,
                                 Supplier<T> supplier,
                                 Completable<? super T> future,
                                 int parallelism)

Method Detail

failed

public void failed(Throwable cause)

Description copied from interface: Handle

Handle to be called when the underlying stage is failed.

Specified by:

failed in interface Handle<S>

Parameters:

cause - exception that caused the underlying stage to fail

completed

public void completed(S result)

Description copied from interface: Handle

Handle to be called when the underlying stage is completed.

Specified by:

completed in interface Handle<S>

Parameters:

result - The result of the completed stage.

cancelled

public void cancelled()

Description copied from interface: Handle

Handle to be called when the underlying stage is cancelled.

Specified by:

cancelled in interface Handle<S>

run

public void run()

Specified by:

run in interface Runnable