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, chainAsync, get, isCancelled, isDone, listen, listenAsync
String 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
0
if there is no next execution time.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>
CancellationException
IgniteInterruptedException
- 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.CancellationException
IgniteInterruptedException
- Subclass of IgniteException
thrown if the wait was interrupted.IgniteFutureTimeoutException
- Subclass of IgniteException
thrown if the wait was timed out.IgniteException
- If computation failed.
GridGain In-Memory Computing Platform : ver. 8.9.14 Release Date : November 5 2024