com.hazelcast.spi.impl.executionservice.impl

Class DelegatingTaskScheduler

java.lang.Object

com.hazelcast.spi.impl.executionservice.impl.DelegatingTaskScheduler

All Implemented Interfaces:

TaskScheduler, Executor

public final class DelegatingTaskScheduler
extends Object
implements TaskScheduler

Constructor Summary

Constructors

Constructor and Description
DelegatingTaskScheduler(ScheduledExecutorService scheduledExecutorService, ExecutorService executor)

Method Summary

Modifier and Type	Method and Description
void	execute(Runnable command)
<V> ScheduledFuture<Future<V>>	schedule(Callable<V> command, long delay, TimeUnit unit) Creates and executes a one-shot action that becomes enabled after the given delay.
ScheduledFuture<?>	schedule(Runnable command, long delay, TimeUnit unit) Creates and executes a one-shot action that becomes enabled after the given delay.
ScheduledFuture<?>	scheduleWithRepetition(Runnable command, long initialDelay, long period, TimeUnit unit) Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DelegatingTaskScheduler

public DelegatingTaskScheduler(ScheduledExecutorService scheduledExecutorService,
                               ExecutorService executor)

Method Detail

execute

public void execute(Runnable command)

Specified by:

execute in interface Executor

schedule

public ScheduledFuture<?> schedule(Runnable command,
                                   long delay,
                                   TimeUnit unit)

Description copied from interface: TaskScheduler

Creates and executes a one-shot action that becomes enabled after the given delay.

Specified by:

schedule in interface TaskScheduler

Parameters:

command - the task to execute

delay - the time from now to delay execution

unit - the time unit of the delay parameter

Returns:

a ScheduledFuture representing pending completion of the task and whose get() method will return null upon completion

schedule

public <V> ScheduledFuture<Future<V>> schedule(Callable<V> command,
                                               long delay,
                                               TimeUnit unit)

Description copied from interface: TaskScheduler

Creates and executes a one-shot action that becomes enabled after the given delay.

Specified by:

schedule in interface TaskScheduler

Parameters:

command - the task to execute

delay - the time from now to delay execution

unit - the time unit of the delay parameter

Returns:

a ScheduledFuture representing pending completion of the task and whose get() method will return <V> upon completion

scheduleWithRepetition

public ScheduledFuture<?> scheduleWithRepetition(Runnable command,
                                                 long initialDelay,
                                                 long period,
                                                 TimeUnit unit)

Description copied from interface: TaskScheduler

Creates and executes a periodic action that becomes enabled first after the given initial delay, and subsequently with the given period. Executions will commence after initialDelay then initialDelay+period, then initialDelay + 2 * period, and so on. If any execution of this task takes longer than its period, then subsequent execution will be skipped.

Specified by:

scheduleWithRepetition in interface TaskScheduler

Parameters:

command - the task to execute

initialDelay - the time to delay first execution

period - the period between successive executions

unit - the time unit of the initialDelay and period parameters

Returns:

a ScheduledFuture representing pending completion of the task, and whose get() method will throw an exception upon cancellation