Class WorkerUnionBase<T>

All Implemented Interfaces:
AutoCloseable, Runnable, CloseableIteration<T,QueryEvaluationException>, Iteration<T,QueryEvaluationException>, ParallelExecutor<T>
Direct Known Subclasses:
ControlledWorkerUnion, SynchronousWorkerUnion

public abstract class WorkerUnionBase<T> extends UnionExecutorBase<T>
Base class for worker unions providing convenience functions to add tasks.
Andreas Schwarte
See Also:
  • Field Details

  • Constructor Details

    • WorkerUnionBase

      public WorkerUnionBase(QueryInfo queryInfo)
  • Method Details

    • addTask

      public void addTask(ParallelTask<T> task)
      Add a generic parallel task. Note that it is required that the task has this instance as its control.
      task -