Reactor Core 3.6.0 · reactor.core.scheduler

Modifier and Type	Interface and Description
public interface	NonBlocking A marker interface that is detected on `Threads` while executing Reactor blocking APIs, resulting in these calls throwing an exception.
public interface	Scheduler Provides an abstract asynchronous boundary to operators.

Class Summary

Modifier and Type	Class and Description
pack-priv class	BoundedElasticScheduler Scheduler that hosts a pool of 0-N single-threaded `BoundedScheduledExecutorService` and exposes workers backed by these executors, making it suited for moderate amount of blocking work.
pack-priv class	BoundedElasticSchedulerSupplier JDK 8 Specific implementation of BoundedElasticScheduler supplier which warns when one enables virtual thread support
pack-priv class	DelegateServiceScheduler A simple `Scheduler` which uses a backing `ExecutorService` to schedule Runnables for async operators.
pack-priv class	DelegatingScheduledExecutorService
pack-priv class	EmptyCompositeDisposable
pack-priv class	ExecutorScheduler Wraps a java.util.concurrent.Executor and provides the Scheduler API over it.
pack-priv class	ExecutorServiceWorker
pack-priv class	ImmediateScheduler Executes tasks on the caller's thread immediately.
pack-priv class	InstantPeriodicWorkerTask A runnable task for `Scheduler` Workers that can run periodically
pack-priv class	ParallelScheduler Scheduler that hosts a fixed pool of single-threaded ScheduledExecutorService-based workers and is suited for parallel work.
pack-priv class	PeriodicSchedulerTask
pack-priv class	PeriodicWorkerTask A runnable task for `Scheduler` Workers that can run periodically
public class	ReactorBlockHoundIntegration `BlockHoundIntegration` with Reactor's scheduling mechanism.
pack-priv class	ReactorThreadFactory The standard Reactor `Thread factories` to be used by `Scheduler`, creating `Thread` with a prefix (which can be retrieved with the `get()` method).
pack-priv class	SchedulerMetricDecorator Deprecated
public abstract class	Schedulers `Schedulers` provides various `Scheduler` flavors usable by `publishOn` or `subscribeOn` : `parallel()`: Optimized for fast `Runnable` non-blocking executions `single`: Optimized for low-latency `Runnable` one-off executions `boundedElastic()`: Optimized for longer executions, an alternative for blocking tasks where the number of active tasks (and threads) is capped `immediate`: to immediately run submitted `Runnable` instead of scheduling them (somewhat of a no-op or "null object" `Scheduler`) `fromExecutorService(ExecutorService)` to create new instances around `java.util.concurrent.Executors`
pack-priv class	SchedulerState<T>
pack-priv class	SchedulerTask
pack-priv class	SingleScheduler Scheduler that works with a single-threaded ScheduledExecutorService and is suited for same-thread work (like an event dispatch thread).
pack-priv class	SingleWorkerScheduler Wraps one of the workers of some other Scheduler and provides Worker services on top of it.
pack-priv class	ThreadPerTaskBoundedElasticScheduler
pack-priv class	VirtualThreadFactory The noop `VirtualThread` Reactor `ThreadFactory` to be used with `ThreadPerTaskBoundedElasticScheduler`.
pack-priv class	WorkerTask A runnable task for `Scheduler` Workers that are time-capable (implementing a relevant schedule(delay) and schedulePeriodically(period) methods).

Package reactor.core.scheduler

Interface Summary

Class Summary