protected static class SourceSelection.SourceSelectionExecutorWithLatch extends Object implements ParallelExecutor<BindingSet>
| Modifier and Type | Method and Description |
|---|---|
void |
addResult(CloseableIteration<BindingSet,QueryEvaluationException> 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 |
run() |
static void |
run(SourceSelection sourceSelection,
List<SourceSelection.CheckTaskPair> tasks,
SourceSelectionCache cache)
Execute the given list of tasks in parallel, and block the thread until all tasks are completed.
|
void |
toss(Exception e)
Toss some exception to the controlling instance
|
public static void run(SourceSelection sourceSelection, List<SourceSelection.CheckTaskPair> tasks, SourceSelectionCache cache)
OptimizationException instances.tasks - public void addResult(CloseableIteration<BindingSet,QueryEvaluationException> res)
ParallelExecutoraddResult in interface ParallelExecutor<BindingSet>public void toss(Exception e)
ParallelExecutortoss in interface ParallelExecutor<BindingSet>public void done()
ParallelExecutordone in interface ParallelExecutor<BindingSet>public boolean isFinished()
ParallelExecutorisFinished in interface ParallelExecutor<BindingSet>public QueryInfo getQueryInfo()
ParallelExecutorgetQueryInfo in interface ParallelExecutor<BindingSet>Copyright © 2015-2021 Eclipse Foundation. All Rights Reserved.