Class ControlledWorkerUnion<T>

All Implemented Interfaces:
AutoCloseable, Runnable, Iterator<T>, CloseableIteration<T>, ParallelExecutor<T>

public class ControlledWorkerUnion<T> extends WorkerUnionBase<T>
Execution of union tasks with ControlledWorkerScheduler. Tasks can be added using the provided functions. Note that the union operation is to be executed with the ParallelExecutorBase.run() method (also threaded execution is possible). Results are then contained in this iteration.
Author:
Andreas Schwarte