public interface IgniteScheduler
GridScheduler is obtained from grid as follows:
GridScheduler s = Ignition.ignite().scheduler();
Scheduler supports standard UNIX cron format with optional prefix of
{n1, n2}, where n1 is delay of scheduling in seconds and
n2 is the number of execution. Both parameters are optional.
Here's an example of scheduling a closure that broadcasts a message
to all nodes five times, once every minute, with initial delay of two seconds:
Ignition.ignite().scheduler().scheduleLocal(
GridSchedulerFuture<?> = Ignition.ignite().scheduler().scheduleLocal(new Callable<Object>() {
@Override public Object call() throws IgniteCheckedException {
g.broadcast(new GridCallable() {...}).get();
}
}, "{2, 5} * * * * *" // 2 seconds delay with 5 executions only.
);
| Modifier and Type | Method and Description |
|---|---|
<R> IgniteFuture<R> |
callLocal(Callable<R> c)
Executes given callable on internal system thread pool asynchronously.
|
IgniteFuture<?> |
runLocal(Runnable r)
Executes given closure on internal system thread pool asynchronously.
|
<R> SchedulerFuture<R> |
scheduleLocal(Callable<R> c,
String ptrn)
Schedules job for execution using local cron-based scheduling.
|
SchedulerFuture<?> |
scheduleLocal(Runnable job,
String ptrn)
Schedules job for execution using local cron-based scheduling.
|
IgniteFuture<?> runLocal(@Nullable Runnable r)
Note that class IgniteRunnable implements Runnable and class IgniteOutClosure
implements Callable interface.
r - Runnable to execute. If null - this method is no-op.callLocal(Callable),
IgniteClosure<R> IgniteFuture<R> callLocal(@Nullable Callable<R> c)
Note that class IgniteRunnable implements Runnable and class IgniteOutClosure
implements Callable interface.
R - Type of the return value for the closure.c - Callable to execute. If null - this method is no-op.runLocal(Runnable),
IgniteOutClosureSchedulerFuture<?> scheduleLocal(Runnable job, String ptrn)
job - Job to schedule to run as a background cron-based job.
If null - this method is no-op.ptrn - Scheduling pattern in UNIX cron format with optional prefix {n1, n2}
where n1 is delay of scheduling in seconds and n2 is the number of execution. Both
parameters are optional.<R> SchedulerFuture<R> scheduleLocal(Callable<R> c, String ptrn)
c - Job to schedule to run as a background cron-based job.ptrn - Scheduling pattern in UNIX cron format with optional prefix {n1, n2}
where n1 is delay of scheduling in seconds and n2 is the number of execution. Both
parameters are optional.
Follow @ApacheIgnite
Ignite Fabric : ver. 1.5.11 Release Date : April 8 2016