hu.akarnokd.reactive4java.scheduler

Class NewThreadScheduler

java.lang.Object

hu.akarnokd.reactive4java.scheduler.NewThreadScheduler

All Implemented Interfaces:

Scheduler

public class NewThreadScheduler
extends java.lang.Object
implements Scheduler

A scheduler which creates separate new threads for each task. To stop a repeating schedule, throw a CancellationException.

Constructor Summary

Constructors

Constructor and Description
NewThreadScheduler() Constructor.
NewThreadScheduler(java.lang.String name) Constructor.

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

NewThreadScheduler

public NewThreadScheduler()

Constructor. The threads are named as NewThreadScheduler-#

NewThreadScheduler

public NewThreadScheduler(@Nonnull
                          java.lang.String name)

Constructor.

Parameters:

name - the name prefix used when creating new threads.

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