hu.akarnokd.reactive4java.scheduler

Class CachedThreadPoolScheduler

java.lang.Object

hu.akarnokd.reactive4java.scheduler.CachedThreadPoolScheduler

All Implemented Interfaces:

Scheduler

public class CachedThreadPoolScheduler
extends java.lang.Object
implements Scheduler

The scheduler uses a cached thread pool executor (via Executors.newCachedThreadPool()) as its backing thread pool. Delayed executions are performed via the TimeUnit.sleep() methods on the pool thread (consuming resources). To stop a repeating schedule, throw a CancellationException.

Since:

0.95

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.ExecutorService	pool The thread pool.

Constructor Summary

Constructors

Constructor and Description
CachedThreadPoolScheduler() 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

Field Detail

pool

protected final java.util.concurrent.ExecutorService pool

The thread pool.

Constructor Detail

CachedThreadPoolScheduler

public CachedThreadPoolScheduler()

Constructor. Initializes the backing thread pool

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