public abstract class ParallelTaskBase<T> extends Object implements ParallelTask<T>
| Modifier and Type | Field and Description |
|---|---|
protected Future<?> |
scheduledFuture |
| Constructor and Description |
|---|
ParallelTaskBase() |
| Modifier and Type | Method and Description |
|---|---|
void |
cancel()
Optional implementation to cancel this task on a best effort basis
|
CloseableIteration<T,QueryEvaluationException> |
performTask() |
protected abstract CloseableIteration<T,QueryEvaluationException> |
performTaskInternal() |
void |
setScheduledFuture(Future<?> future) |
String |
toString() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetControl, getQueryInfoprotected Future<?> scheduledFuture
public void cancel()
ParallelTaskcancel in interface ParallelTask<T>public CloseableIteration<T,QueryEvaluationException> performTask() throws Exception
performTask in interface ParallelTask<T>Exceptionprotected abstract CloseableIteration<T,QueryEvaluationException> performTaskInternal() throws Exception
Exceptionpublic void setScheduledFuture(Future<?> future)
Copyright © 2015-2022 Eclipse Foundation. All Rights Reserved.