- All Superinterfaces:
- All Known Implementing Classes:
public interface ParallelExecutor<T> extends Runnable
Interface for any parallel cursor, i.e. result iterations. Implementations can act as control for scheduler implementations, e.g.
ControlledWorkerScheduler. The common use case is to pass results from the scheduler to the controlling result iteration.
- Andreas Schwarte
- See Also:
Method SummaryModifier and TypeMethodDescription
voidHandle the result appropriately, e.g.
done()Inform the controlling instance that some job is done from a different thread.Return the query info of the associated query
booleanReturn true if this executor is finished or aborted
voidToss some exception to the controlling instance
(CloseableIteration<T, QueryEvaluationException> res)Handle the result appropriately, e.g. add it to the result iteration. Take care for synchronization in a multithreaded environment
(Exception e)Toss some exception to the controlling instance
donevoid done()Inform the controlling instance that some job is done from a different thread. In most cases this is a no-op.
isFinishedboolean isFinished()Return true if this executor is finished or aborted
- whether the execution is finished
getQueryInfoQueryInfo getQueryInfo()Return the query info of the associated query
- the query info