Package org.eclipse.rdf4j.federated.evaluation.concurrent

Interface ParallelExecutor<T>

All Superinterfaces:

Runnable

All Known Implementing Classes:

ControlledWorkerBoundJoin, ControlledWorkerJoin, ControlledWorkerLeftJoin, ControlledWorkerUnion, HashJoin, JoinExecutorBase, ParallelExecutorBase, ParallelServiceExecutor, SourceSelection.SourceSelectionExecutorWithLatch, SynchronousBoundJoin, SynchronousJoin, SynchronousWorkerUnion, UnionExecutorBase, WorkerUnionBase

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.

Author:

Andreas Schwarte

See Also:

• JoinExecutorBase
• UnionExecutorBase

Method Summary

Modifier and Type	Method	Description
void	addResult(CloseableIteration<T> res)	Handle the result appropriately, e.g.
void	done()	Inform the controlling instance that some job is done from a different thread.
QueryInfo	getQueryInfo()	Return the query info of the associated query
boolean	isFinished()	Return true if this executor is finished or aborted
void	toss(Exception e)	Toss some exception to the controlling instance

Methods inherited from interface java.lang.Runnable

run

Method Details

addResult

void addResult(CloseableIteration<T> res)

Handle the result appropriately, e.g. add it to the result iteration. Take care for synchronization in a multithreaded environment

Parameters:

res -

toss

void toss(Exception e)

Toss some exception to the controlling instance

Parameters:

e -

done

void done()

Inform the controlling instance that some job is done from a different thread. In most cases this is a no-op.

isFinished

boolean isFinished()

Return true if this executor is finished or aborted

Returns:

whether the execution is finished

getQueryInfo

QueryInfo getQueryInfo()

Return the query info of the associated query

Returns:

the query info