hu.akarnokd.reactive4java.scheduler

Class DefaultScheduler

java.lang.Object

hu.akarnokd.reactive4java.scheduler.DefaultScheduler

All Implemented Interfaces:

Scheduler

public class DefaultScheduler
extends java.lang.Object
implements Scheduler

The default implementation of the Scheduler interface used by the Reactive operators.

Constructor Summary

Constructors

Constructor and Description
DefaultScheduler() Creates a scheduler with a ScheduledThreadPoolExecutor.
DefaultScheduler(int poolSize) Creates a scheduler with a ScheduledThreadPoolExecutor.
DefaultScheduler(java.util.concurrent.ScheduledExecutorService scheduled) Creates a scheduler instance with the given backing pool.

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.
void	shutdown() Shutdown both pools.
java.util.List<java.lang.Runnable>	shutdownNow() Shutdown both pools now.
protected java.io.Closeable	toCloseable(java.util.concurrent.Future<?> future) Factory function to turn the future into a closeable instance.

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultScheduler

public DefaultScheduler()

Creates a scheduler with a ScheduledThreadPoolExecutor. The pool will have the following attributes:

• Runtime.getRuntime().availableProcessors() core thread
• 1 second idle timeout
• core threads may timeout
• unbounded worker queue
• no rejection handler
• if running on Java 7 or above: remove on cancel policy set to true

DefaultScheduler

public DefaultScheduler(int poolSize)

Creates a scheduler with a ScheduledThreadPoolExecutor. The pool will have the following attributes:

• parallellism core thread
• 1 second idle timeout
• core threads may timeout
• unbounded worker queue
• no rejection handler
• if running on Java 7 or above: remove on cancel policy set to true

Parameters:

poolSize - the number of core threads

Since:

0.97

DefaultScheduler

public DefaultScheduler(@Nonnull
                        java.util.concurrent.ScheduledExecutorService scheduled)

Creates a scheduler instance with the given backing pool.

Parameters:

scheduled - the backing scheduled executor service

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

toCloseable

@Nonnull
protected java.io.Closeable toCloseable(@Nonnull
                                                  java.util.concurrent.Future<?> future)

Factory function to turn the future into a closeable instance.

Parameters:

future - the future to work with

Returns:

the closeable instance

Since:

0.97

shutdown

public void shutdown()

Shutdown both pools.

shutdownNow

public java.util.List<java.lang.Runnable> shutdownNow()

Shutdown both pools now.

Returns:

the list of runnable tasks awaiting executions in both pools