Class ParallelTaskBase<T>
java.lang.Object
org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelTaskBase<T>
- All Implemented Interfaces:
ParallelTask<T>
- Direct Known Subclasses:
ParallelBoundJoinTask,ParallelCheckJoinTask,ParallelGetStatementsTask,ParallelJoinTask,ParallelLeftJoinTask,ParallelPreparedAlgebraUnionTask,ParallelPreparedUnionTask,ParallelServiceJoinTask,ParallelUnionOperatorTask,ParallelUnionTask,SourceSelection.ParallelCheckTask
-
Field Summary
Fields -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidcancel()Optional implementation to cancel this task on a best effort basisvoidclose()Optional implementation to close this task on a best effort basis.protected abstract CloseableIteration<T,QueryEvaluationException> voidsetScheduledFuture(Future<?> future) toString()Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.eclipse.rdf4j.federated.evaluation.concurrent.ParallelTask
getControl, getQueryInfo
-
Field Details
-
scheduledFuture
-
-
Constructor Details
-
ParallelTaskBase
public ParallelTaskBase()
-
-
Method Details
-
cancel
public void cancel()Description copied from interface:ParallelTaskOptional implementation to cancel this task on a best effort basis- Specified by:
cancelin interfaceParallelTask<T>
-
performTask
- Specified by:
performTaskin interfaceParallelTask<T>- Throws:
Exception
-
performTaskInternal
protected abstract CloseableIteration<T,QueryEvaluationException> performTaskInternal() throws Exception- Throws:
Exception
-
setScheduledFuture
-
toString
-
close
public void close()Description copied from interface:ParallelTaskOptional implementation to close this task on a best effort basis.- Specified by:
closein interfaceParallelTask<T>
-