public interface Scheduler<T>
ControlledWorkerScheduler| Modifier and Type | Method and Description |
|---|---|
void |
abort()
Abort the execution of running and queued tasks.
|
void |
done()
Inform the scheduler that a certain task is done.
|
void |
handleResult(CloseableIteration<T,QueryEvaluationException> res)
Callback to handle the result.
|
void |
informFinish()
Inform the scheduler that no more tasks will be scheduled.
|
boolean |
isRunning()
Determine if the scheduler has unfinished tasks.
|
void |
schedule(ParallelTask<T> task)
Schedule the provided task.
|
void |
shutdown() |
void |
toss(Exception e)
Toss an exception to the scheduler.
|
void schedule(ParallelTask<T> task)
task - void handleResult(CloseableIteration<T,QueryEvaluationException> res)
res - void done()
void toss(Exception e)
e - void abort()
void shutdown()
void informFinish()
boolean isRunning()
Copyright © 2015-2022 Eclipse Foundation. All Rights Reserved.