reactor.core.scheduler

Class Schedulers

java.lang.Object

reactor.core.scheduler.Schedulers

public class Schedulers
extends java.lang.Object

Schedulers provide various Scheduler generator useable by publishOn or subscribeOn :

• fromExecutorService(ExecutorService)}.
• newParallel(java.lang.String) : Optimized for fast Runnable executions
• single() : Optimized for low-latency Runnable executions
• immediate().

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	Schedulers.Factory Public factory hook to override Schedulers behavior globally

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_POOL_SIZE Default number of processors available to the runtime on init (min 4)

Constructor Summary

Constructors

Constructor and Description
Schedulers()

Method Summary

Modifier and Type	Method and Description
static Scheduler	elastic() Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
static Scheduler	fromExecutor(java.util.concurrent.Executor executor) Create a Scheduler which uses a backing Executor to schedule Runnables for async operators.
static Scheduler	fromExecutor(java.util.concurrent.Executor executor, boolean trampoline) Create a Scheduler which uses a backing Executor to schedule Runnables for async operators.
static Scheduler	fromExecutorService(java.util.concurrent.ExecutorService executorService) Create a Scheduler which uses a backing ExecutorService to schedule Runnables for async operators.
static Scheduler	immediate() Executes tasks on the caller's thread immediately.
static Scheduler	newElastic(int ttlSeconds, java.util.concurrent.ThreadFactory threadFactory) Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
static Scheduler	newElastic(java.lang.String name) Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
static Scheduler	newElastic(java.lang.String name, int ttlSeconds) Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
static Scheduler	newElastic(java.lang.String name, int ttlSeconds, boolean daemon) Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.
static Scheduler	newParallel(int parallelism, java.util.concurrent.ThreadFactory threadFactory) Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
static Scheduler	newParallel(java.lang.String name) Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
static Scheduler	newParallel(java.lang.String name, int parallelism) Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
static Scheduler	newParallel(java.lang.String name, int parallelism, boolean daemon) Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
static Scheduler	newSingle(java.lang.String name) Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
static Scheduler	newSingle(java.lang.String name, boolean daemon) Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
static Scheduler	newSingle(java.util.concurrent.ThreadFactory threadFactory) Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
static TimedScheduler	newTimer(java.lang.String name) Create a new TimedScheduler backed by a single threaded ScheduledExecutorService.
static TimedScheduler	newTimer(java.lang.String name, boolean daemon) Create a new TimedScheduler backed by a single threaded ScheduledExecutorService.
static TimedScheduler	newTimer(java.util.concurrent.ThreadFactory threadFactory) Create a new TimedScheduler backed by a single threaded ScheduledExecutorService.
static Scheduler	parallel() Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.
static void	resetFactory() Re-apply default factory to Schedulers
static void	setFactory(Schedulers.Factory factoryInstance) Override Schedulers finite signatures of newParallel(java.lang.String), newSingle(java.lang.String), newTimer(java.lang.String) and newElastic(java.lang.String) factory using the matching method signature in the target class.
static void	shutdownNow() Clear any cached Scheduler and call shutdown on them.
static Scheduler	single() Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.
static Scheduler	single(Scheduler original) Wraps a single worker of some other Scheduler and provides Scheduler.Worker services on top of it.
static TimedScheduler	timer() Create or reuse a hash-wheel based TimedScheduler with a resolution of 50MS All times will rounded up to the closest multiple of this resolution.

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_POOL_SIZE

public static final int DEFAULT_POOL_SIZE

Default number of processors available to the runtime on init (min 4)

See Also:

Runtime.availableProcessors()

Constructor Detail

Schedulers

public Schedulers()

Method Detail

fromExecutor

public static Scheduler fromExecutor(java.util.concurrent.Executor executor)

Create a Scheduler which uses a backing Executor to schedule Runnables for async operators.

Parameters:

executor - an Executor

Returns:

a new Scheduler

fromExecutor

public static Scheduler fromExecutor(java.util.concurrent.Executor executor,
                                     boolean trampoline)

Create a Scheduler which uses a backing Executor to schedule Runnables for async operators.

Parameters:

executor - an Executor

trampoline - set to false if this Scheduler is used by "operators" that already conflate Runnable executions (publishOn, subscribeOn...)

Returns:

a new Scheduler

fromExecutorService

public static Scheduler fromExecutorService(java.util.concurrent.ExecutorService executorService)

Create a Scheduler which uses a backing ExecutorService to schedule Runnables for async operators.

Parameters:

executorService - an ExecutorService

Returns:

a new Scheduler

elastic

public static Scheduler elastic()

Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.

The maximum number of created thread pools is unbounded.

The default time-to-live for unused thread pools is 60 seconds, use the appropriate factory to set a different value.

This scheduler is not restartable.

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

immediate

public static Scheduler immediate()

Executes tasks on the caller's thread immediately.

Returns:

a reusable Scheduler

newElastic

public static Scheduler newElastic(java.lang.String name)

Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.

The maximum number of created thread pools is unbounded.

The default time-to-live for unused thread pools is 60 seconds, use the appropriate factory to set a different value.

This scheduler is not restartable.

Parameters:

name - Thread prefix

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

newElastic

public static Scheduler newElastic(java.lang.String name,
                                   int ttlSeconds)

Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.

The maximum number of created thread pools is unbounded.

This scheduler is not restartable.

Parameters:

name - Thread prefix

ttlSeconds - Time-to-live for an idle Scheduler.Worker

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

newElastic

public static Scheduler newElastic(java.lang.String name,
                                   int ttlSeconds,
                                   boolean daemon)

Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.

The maximum number of created thread pools is unbounded.

This scheduler is not restartable.

Parameters:

name - Thread prefix

ttlSeconds - Time-to-live for an idle Scheduler.Worker

daemon - false if the Scheduler requires an explicit Scheduler.shutdown() to exit the VM.

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

newElastic

public static Scheduler newElastic(int ttlSeconds,
                                   java.util.concurrent.ThreadFactory threadFactory)

Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.

The maximum number of created thread pools is unbounded.

This scheduler is not restartable.

Parameters:

ttlSeconds - Time-to-live for an idle Scheduler.Worker

threadFactory - a ThreadFactory to use each thread initialization

Returns:

a new Scheduler that dynamically creates ExecutorService-based Workers and caches the thread pools, reusing them once the Workers have been shut down.

newParallel

public static Scheduler newParallel(java.lang.String name)

Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.

Parameters:

name - Thread prefix

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

newParallel

public static Scheduler newParallel(java.lang.String name,
                                    int parallelism)

Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.

Parameters:

name - Thread prefix

parallelism - Number of pooled workers.

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

newParallel

public static Scheduler newParallel(java.lang.String name,
                                    int parallelism,
                                    boolean daemon)

Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.

Parameters:

name - Thread prefix

parallelism - Number of pooled workers.

daemon - false if the Scheduler requires an explicit Scheduler.shutdown() to exit the VM.

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

newParallel

public static Scheduler newParallel(int parallelism,
                                    java.util.concurrent.ThreadFactory threadFactory)

Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.

Parameters:

parallelism - Number of pooled workers.

threadFactory - a ThreadFactory to use for the fixed initialized number of Thread

Returns:

a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work

newSingle

public static Scheduler newSingle(java.lang.String name)

Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.

Parameters:

name - Component and thread name prefix

Returns:

a new Scheduler that hosts a single-threaded ExecutorService-based worker

newSingle

public static Scheduler newSingle(java.lang.String name,
                                  boolean daemon)

Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.

Parameters:

name - Component and thread name prefix

daemon - false if the Scheduler requires an explicit Scheduler.shutdown() to exit the VM.

Returns:

a new Scheduler that hosts a single-threaded ExecutorService-based worker

newSingle

public static Scheduler newSingle(java.util.concurrent.ThreadFactory threadFactory)

Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work.

Parameters:

threadFactory - a ThreadFactory to use for the unique thread of the Scheduler

Returns:

a new Scheduler that hosts a single-threaded ExecutorService-based worker

newTimer

public static TimedScheduler newTimer(java.lang.String name)

Create a new TimedScheduler backed by a single threaded ScheduledExecutorService.

Parameters:

name - timer thread prefix

Returns:

a new TimedScheduler

newTimer

public static TimedScheduler newTimer(java.lang.String name,
                                      boolean daemon)

Create a new TimedScheduler backed by a single threaded ScheduledExecutorService.

Parameters:

name - Component and thread name prefix

daemon - false if the Scheduler requires an explicit Scheduler.shutdown() to exit the VM.

Returns:

a new TimedScheduler

newTimer

public static TimedScheduler newTimer(java.util.concurrent.ThreadFactory threadFactory)

Create a new TimedScheduler backed by a single threaded ScheduledExecutorService.

Parameters:

threadFactory - a ThreadFactory to use for the unique thread of the TimedScheduler

Returns:

a new TimedScheduler

parallel

public static Scheduler parallel()

Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work.

Returns:

a reusable Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers

resetFactory

public static void resetFactory()

Re-apply default factory to Schedulers

setFactory

public static void setFactory(Schedulers.Factory factoryInstance)

Override Schedulers finite signatures of newParallel(java.lang.String), newSingle(java.lang.String), newTimer(java.lang.String) and newElastic(java.lang.String) factory using the matching method signature in the target class. A finite signature corresponds to those including a ThreadFactory argument and should be instance methods.

This method should be called safely and with caution, typically on app startup.

Parameters:

factoryInstance - an arbitrary Schedulers.Factory instance.

shutdownNow

public static void shutdownNow()

Clear any cached Scheduler and call shutdown on them.

single

public static Scheduler single()

Scheduler that hosts a single-threaded ExecutorService-based worker and is suited for parallel work. Will cache the returned schedulers for subsequent single() calls until shutdown.

Returns:

a cached Scheduler that hosts a single-threaded ExecutorService-based worker

single

public static Scheduler single(Scheduler original)

Wraps a single worker of some other Scheduler and provides Scheduler.Worker services on top of it.

Use the Scheduler.shutdown() to release the wrapped worker.

Parameters:

original - a Scheduler to call upon to get the single Scheduler.Worker

Returns:

a wrapping Scheduler consistently returning a same worker from a source Scheduler

timer

public static TimedScheduler timer()

Create or reuse a hash-wheel based TimedScheduler with a resolution of 50MS All times will rounded up to the closest multiple of this resolution.

Returns:

a cached hash-wheel based TimedScheduler