hu.akarnokd.reactive4java.base

Interface Scheduler

All Known Implementing Classes:

CachedThreadPoolScheduler, CurrentThreadScheduler, DefaultEdtScheduler, DefaultScheduler, NewThreadScheduler

public interface Scheduler

An abstract interface for defining minimum scheduling capabilities.

Method Summary

Modifier and Type	Method and Description
java.io.Closeable	schedule(java.lang.Runnable run) Schedule for ASAP execution.
java.io.Closeable	schedule(java.lang.Runnable run, long initialDelay, long betweenDelay, java.util.concurrent.TimeUnit unit) Schedule a repeated execution of the given task with the given initialDelay (in nanoseconds) and betweenDelay (in nanoseconds).
java.io.Closeable	schedule(java.lang.Runnable run, long delay, java.util.concurrent.TimeUnit unit) Schedule a single execution of the runnable task with the given delay of nanoseconds.

Method Detail

schedule

@Nonnull
java.io.Closeable schedule(@Nonnull
                                     java.lang.Runnable run)

Schedule for ASAP execution.

Parameters:

run - the runnable task

Returns:

the cancel handler

schedule

@Nonnull
java.io.Closeable schedule(@Nonnull
                                     java.lang.Runnable run,
                                     long delay,
                                     @Nonnull
                                     java.util.concurrent.TimeUnit unit)

Schedule a single execution of the runnable task with the given delay of nanoseconds.

Parameters:

run - the task to run

delay - the initial delay,

unit - the delay time unit implementations might not have the capability to schedule in this resolution

Returns:

the cancel handler

schedule

@Nonnull
java.io.Closeable schedule(@Nonnull
                                     java.lang.Runnable run,
                                     long initialDelay,
                                     long betweenDelay,
                                     @Nonnull
                                     java.util.concurrent.TimeUnit unit)

Schedule a repeated execution of the given task with the given initialDelay (in nanoseconds) and betweenDelay (in nanoseconds). The expected semantics from the scheduler is to run the task at a fixed rate (i.e., ExecutorService.scheduleAtFixedRate()). Note: Implementations might not have the capability to schedule nanosecond resolution.

Parameters:

run - the task to run

initialDelay - the initial delay before the first run

betweenDelay - the delay between task runs after the

unit - the delay time unit

Returns:

the cancel handler