Scheduler implementations.See: Description
| Class | Description |
|---|---|
| CachedThreadPoolScheduler |
The scheduler uses a cached thread pool executor (via
Executors.newCachedThreadPool()) as its backing thread pool. |
| CurrentThreadScheduler |
Scheduler which runs tasks on the current thread.
|
| DefaultScheduler |
The default implementation of the Scheduler
interface used by the
Reactive operators. |
| NewThreadScheduler |
A scheduler which creates separate new threads for each task.
|
| SingleLaneExecutor<T> |
A helper class which ensures that each of its queued
elements get processed in sequence even on a multi-threaded pool.
|
Scheduler implementations.