Class WorkerUnionBase<T>
- java.lang.Object
-
- org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration<E,X>
-
- org.eclipse.rdf4j.common.iteration.LookAheadIteration<T,QueryEvaluationException>
-
- org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase<T>
-
- org.eclipse.rdf4j.federated.evaluation.union.UnionExecutorBase<T>
-
- org.eclipse.rdf4j.federated.evaluation.union.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.- Author:
- Andreas Schwarte
- See Also:
SynchronousWorkerUnion,ControlledWorkerUnion
-
-
Field Summary
Fields Modifier and Type Field Description protected List<ParallelTask<T>>tasks-
Fields inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase
evaluationThread, executorId, finished, log, NEXT_EXECUTOR_ID, queryInfo, rightIter, rightQueue, strategy
-
-
Constructor Summary
Constructors Constructor Description WorkerUnionBase(QueryInfo queryInfo)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaddTask(ParallelTask<T> task)Add a generic parallel task.voidhandleClose()Called byAbstractCloseableIteration.close()when it is called for the first time.-
Methods inherited from class org.eclipse.rdf4j.federated.evaluation.union.UnionExecutorBase
getExecutorType, performExecution, union
-
Methods inherited from class org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelExecutorBase
addResult, checkTimeout, done, getDisplayId, getId, getNextElement, getQueryInfo, isFinished, run, toss, toString
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.LookAheadIteration
hasNext, next, remove
-
Methods inherited from class org.eclipse.rdf4j.common.iteration.AbstractCloseableIteration
close, isClosed
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.eclipse.rdf4j.common.iteration.CloseableIteration
stream
-
-
-
-
Field Detail
-
tasks
protected List<ParallelTask<T>> tasks
-
-
Constructor Detail
-
WorkerUnionBase
public WorkerUnionBase(QueryInfo queryInfo)
-
-
Method Detail
-
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.- Parameters:
task-
-
handleClose
public void handleClose() throws QueryEvaluationExceptionDescription copied from class:AbstractCloseableIterationCalled byAbstractCloseableIteration.close()when it is called for the first time. This method is only called once on each iteration. By default, this method does nothing.- Overrides:
handleClosein classParallelExecutorBase<T>- Throws:
QueryEvaluationException
-
-