Schedulers (reactor-core 3.0.0.RC1 API)

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().

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)

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()

Constructors
Constructor and Description
`Schedulers()`

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static Scheduler`	`computation()` `Scheduler` that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
`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`	`newComputation(int parallelism, int bufferSize, java.util.concurrent.ThreadFactory threadFactory)` `Scheduler` that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
`static Scheduler`	`newComputation(java.lang.String name)` `Scheduler` that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
`static Scheduler`	`newComputation(java.lang.String name, int parallelism)` `Scheduler` that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
`static Scheduler`	`newComputation(java.lang.String name, int parallelism, boolean daemon)` `Scheduler` that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
`static Scheduler`	`newComputation(java.lang.String name, int parallelism, int bufferSize)` `Scheduler` that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
`static Scheduler`	`newComputation(java.lang.String name, int parallelism, int bufferSize, boolean daemon)` `Scheduler` that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
`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`	`setComputationFactory(java.lang.Class<?> factoryClass)` Assign a `newComputation(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
  - computation
```
public static Scheduler computation()
```
    Scheduler that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
    
    Returns:
    
    a reusable Scheduler that hosts a fixed pool of single-threaded Event-Loop based workers
  - 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
  - newComputation
```
public static Scheduler newComputation(java.lang.String name)
```
    Scheduler that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking 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
  - newComputation
```
public static Scheduler newComputation(java.lang.String name,
                                       int parallelism)
```
    Scheduler that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking 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
  - newComputation
```
public static Scheduler newComputation(java.lang.String name,
                                       int parallelism,
                                       int bufferSize)
```
    Scheduler that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
    
    Parameters:
    
    name - Thread prefix
    
    parallelism - Number of pooled workers.
    
    bufferSize - backlog size to be used by event loops.
    
    Returns:
    
    a new Scheduler that hosts a fixed pool of single-threaded ExecutorService-based workers and is suited for parallel work
  - newComputation
```
public static Scheduler newComputation(java.lang.String name,
                                       int parallelism,
                                       boolean daemon)
```
    Scheduler that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking 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
  - newComputation
```
public static Scheduler newComputation(java.lang.String name,
                                       int parallelism,
                                       int bufferSize,
                                       boolean daemon)
```
    Scheduler that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
    
    Parameters:
    
    name - Thread prefix
    
    parallelism - Number of pooled workers.
    
    bufferSize - backlog size to be used by event loops.
    
    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
  - newComputation
```
public static Scheduler newComputation(int parallelism,
                                       int bufferSize,
                                       java.util.concurrent.ThreadFactory threadFactory)
```
    Scheduler that hosts a fixed pool of single-threaded Event Loop based workers and is suited for non blocking work.
    
    Parameters:
    
    parallelism - Number of pooled workers.
    
    bufferSize - backlog size to be used by event loops.
    
    threadFactory - a ThreadFactory to use for the unique thread of the Scheduler
    
    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)
```
    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 for the unique thread of the Scheduler
    
    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 unique thread of the Scheduler
    
    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 Scheduler
    
    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
  - setComputationFactory
```
public static void setComputationFactory(java.lang.Class<?> factoryClass)
```
    Assign a newComputation(java.lang.String) factory using the matching method signature in the target class.
    
    Parameters:
    
    factoryClass - an arbitrary type with static methods matching newComputation(java.lang.String) signature(s).
  - 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

Class Schedulers

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

DEFAULT_POOL_SIZE

Constructor Detail

Schedulers

Method Detail

computation

fromExecutor

fromExecutor

fromExecutorService

elastic

immediate

newComputation

newComputation

newComputation

newComputation

newComputation

newComputation

newElastic

newElastic

newElastic

newElastic

newParallel

newParallel

newParallel

newParallel

newSingle

newSingle

newSingle

newTimer

newTimer

newTimer

parallel

setComputationFactory

shutdownNow

single

single

timer