public interface SchedulerFuture<R> extends IgniteFuture<R>
IgniteScheduler.scheduleLocal(Callable, String) or
IgniteScheduler.scheduleLocal(Runnable, String) methods.| Modifier and Type | Method and Description |
|---|---|
double |
averageExecutionTime()
Gets average execution time in milliseconds since future was created.
|
double |
averageIdleTime()
Gets average idle time for this scheduled task.
|
int |
count()
Gets total count of executions this task has already completed.
|
long |
createTime()
Gets time in milliseconds at which this future was created.
|
R |
get()
Waits for the completion of the next scheduled execution and returns its result.
|
R |
get(long timeout,
TimeUnit unit)
Waits for the completion of the next scheduled execution for
specified amount of time and returns its result.
|
String |
id()
Gets scheduled task ID.
|
boolean |
isRunning()
Returns
true if scheduled task is currently running. |
R |
last()
Gets result of the last execution of scheduled task, or
null if task has not been executed, or has not
produced a result yet. |
long |
lastFinishTime()
Gets finish time of last execution (
0 if first execution has not finished). |
long |
lastIdleTime()
Gets last interval between scheduled executions.
|
long |
lastStartTime()
Gets start time of last execution (
0 if never started). |
long |
nextExecutionTime()
Gets next execution time of scheduled task.
|
long[] |
nextExecutionTimes(int cnt,
long start)
Gets an array of the next execution times after passed
start timestamp. |
String |
pattern()
Gets scheduling pattern.
|
cancel, chain, duration, get, isCancelled, isDone, listen, startTimeString id()
String pattern()
long createTime()
long lastStartTime()
0 if never started).long lastFinishTime()
0 if first execution has not finished).0 if first execution has not finished).double averageExecutionTime()
long lastIdleTime()
double averageIdleTime()
long[] nextExecutionTimes(int cnt,
long start)
throws IgniteException
start timestamp.cnt - Array length.start - Start timestamp.IgniteException - Thrown in case of any errors.int count()
boolean isRunning()
true if scheduled task is currently running.True if scheduled task is currently running.long nextExecutionTime()
throws IgniteException
IgniteException - Thrown in case of any errors.R last() throws IgniteException
null if task has not been executed, or has not
produced a result yet.null if
there isn't one yet.IgniteException - If last execution resulted in exception.R get()
get in interface IgniteFuture<R>CancellationExceptionIgniteInterruptedException - Subclass of IgniteException thrown if the wait was interrupted.IgniteException - If computation failed.R get(long timeout, TimeUnit unit)
get in interface IgniteFuture<R>timeout - The maximum time to wait.unit - The time unit of the timeout argument.CancellationExceptionIgniteInterruptedException - Subclass of IgniteException thrown if the wait was interrupted.IgniteFutureTimeoutException - Subclass of IgniteException thrown if the wait was timed out.IgniteException - If computation failed.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016