reactor.core.scheduler

Interface Schedulers.Factory

Enclosing class:

Schedulers

public static interface Schedulers.Factory

Public factory hook to override Schedulers behavior globally

Method Summary

Modifier and Type	Method and Description
default ScheduledExecutorService	decorateExecutorService(String schedulerType, Supplier<? extends ScheduledExecutorService> actual) Override this method to decorate ScheduledExecutorService internally used by Reactor's various Scheduler implementations, allowing to tune the ScheduledExecutorService backing implementation.
default Scheduler	newElastic(int ttlSeconds, ThreadFactory threadFactory) Scheduler that dynamically creates Workers resources and caches eventually, reusing them once the Workers have been shut down.
default Scheduler	newParallel(int parallelism, ThreadFactory threadFactory) Scheduler that hosts a fixed pool of workers and is suited for parallel work.
default Scheduler	newSingle(ThreadFactory threadFactory) Scheduler that hosts a single worker and is suited for non-blocking work.

Method Detail

decorateExecutorService

default ScheduledExecutorService decorateExecutorService(String schedulerType,
                                                         Supplier<? extends ScheduledExecutorService> actual)

Override this method to decorate ScheduledExecutorService internally used by Reactor's various Scheduler implementations, allowing to tune the ScheduledExecutorService backing implementation.

Parameters:

schedulerType - a name hinting at the flavor of Scheduler being tuned.

actual - the default backing implementation, provided lazily as a Supplier so that you can bypass instantiation completely if you want to replace it.

Returns:

the internal ScheduledExecutorService instance to use.

newElastic

default Scheduler newElastic(int ttlSeconds,
                             ThreadFactory threadFactory)

Scheduler that dynamically creates Workers resources and caches eventually, reusing them once the Workers have been shut down.

The maximum number of created workers is unbounded.

Parameters:

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

threadFactory - a ThreadFactory to use

Returns:

a new Scheduler that dynamically creates Workers resources and caches eventually, reusing them once the Workers have been shut down.

newParallel

default Scheduler newParallel(int parallelism,
                              ThreadFactory threadFactory)

Scheduler that hosts a fixed pool of 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 workers and is suited for parallel work

newSingle

default Scheduler newSingle(ThreadFactory threadFactory)

Scheduler that hosts a single worker and is suited for non-blocking work.

Parameters:

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

Returns:

a new Scheduler that hosts a single worker