hu.akarnokd.reactive4java.swing

Class DefaultEdtScheduler

java.lang.Object

hu.akarnokd.reactive4java.swing.DefaultEdtScheduler

All Implemented Interfaces:

Scheduler

public class DefaultEdtScheduler
extends java.lang.Object
implements Scheduler

The default Event Dispatch Thread scheduler implementation. Which ensures that all tasks submitted to it will run on the EDT.

Use with the Reactive.subscribeOn and Reactive.observeOn operators to ensure your code interacts with Swing objects on the EDT.

See Also:

Reactive.observeOn(hu.akarnokd.reactive4java.base.Observable, Scheduler), Reactive.registerOn(hu.akarnokd.reactive4java.base.Observable, Scheduler)

Constructor Summary

Constructors

Constructor and Description
DefaultEdtScheduler()

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.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultEdtScheduler

public DefaultEdtScheduler()

Method Detail

schedule

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

Description copied from interface: Scheduler

Schedule for ASAP execution.

Specified by:

schedule in interface Scheduler

Parameters:

run - the runnable task

Returns:

the cancel handler

schedule

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

Description copied from interface: Scheduler

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

Specified by:

schedule in interface Scheduler

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
public java.io.Closeable schedule(@Nonnull
                                            java.lang.Runnable run,
                                            long initialDelay,
                                            long betweenDelay,
                                            @Nonnull
                                            java.util.concurrent.TimeUnit unit)

Description copied from interface: Scheduler

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.

Specified by:

schedule in interface Scheduler

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