Interface ParallelTask<T>
-
- All Known Implementing Classes:
ParallelBoundJoinTask,ParallelCheckJoinTask,ParallelGetStatementsTask,ParallelJoinTask,ParallelLeftJoinTask,ParallelPreparedAlgebraUnionTask,ParallelPreparedUnionTask,ParallelServiceJoinTask,ParallelTaskBase,ParallelUnionOperatorTask,ParallelUnionTask,SourceSelection.ParallelCheckTask
public interface ParallelTask<T>Interface for any parallel task that can be performed in Scheduler implementations.- Author:
- Andreas Schwarte
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description voidcancel()Optional implementation to cancel this task on a best effort basisdefault voidclose()Optional implementation to close this task on a best effort basis.ParallelExecutor<T>getControl()return the controlling instance, e.g.default QueryInfogetQueryInfo()CloseableIteration<T>performTask()
-
-
-
Method Detail
-
performTask
CloseableIteration<T> performTask() throws Exception
- Throws:
Exception
-
getControl
ParallelExecutor<T> getControl()
return the controlling instance, e.g. in most cases the instance of a thread. Shared variables are used to inform the thread about new events.- Returns:
- the control executor
-
cancel
void cancel()
Optional implementation to cancel this task on a best effort basis
-
close
default void close()
Optional implementation to close this task on a best effort basis.
-
-