public abstract class WorkerUnionBase<T> extends UnionExecutorBase<T>
SynchronousWorkerUnion,
ControlledWorkerUnion| Modifier and Type | Field and Description |
|---|---|
protected List<ParallelTask<T>> |
tasks |
evaluationThread, executorId, finished, log, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy| Constructor and Description |
|---|
WorkerUnionBase(FederationEvalStrategy strategy,
QueryInfo queryInfo) |
| Modifier and Type | Method and Description |
|---|---|
void |
addTask(ParallelTask<T> task)
Add a generic parallel task.
|
getExecutorType, performExecution, unionaddResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, handleClose, isFinished, run, toss, toStringhasNext, next, removeclose, isClosedprotected List<ParallelTask<T>> tasks
public WorkerUnionBase(FederationEvalStrategy strategy, QueryInfo queryInfo)
public void addTask(ParallelTask<T> task)
task - Copyright © 2015-2022 Eclipse Foundation. All Rights Reserved.