public final class Schedulers extends Object
| Modifier and Type | Method and Description |
|---|---|
static Scheduler |
computation()
Creates and returns a
Scheduler intended for computational work.
|
static Scheduler |
from(Executor
Converts an
Executor into a new Scheduler instance.
|
static Scheduler |
immediate()
Creates and returns a
Scheduler that executes work immediately on the current thread.
|
static Scheduler |
io()
Creates and returns a
Scheduler intended for IO-bound work.
|
static Scheduler |
newThread()
|
static TestScheduler |
test()
Creates and returns a
TestScheduler, which is useful for debugging.
|
static Scheduler |
trampoline()
Creates and returns a
Scheduler that queues work on the current thread to be executed after the current work completes.
|
public static Schedulerimmediate()
Scheduler that executes work immediately on the current thread.
ImmediateScheduler instance
public static Schedulertrampoline()
Scheduler that queues work on the current thread to be executed after the current work completes.
TrampolineScheduler instance
public static SchedulernewThread()
Scheduler that creates a new
Thread for each unit of work.
Unhandled errors will be delivered to the scheduler Thread's Thread.UncaughtExceptionHandler.
NewThreadScheduler instance
public static Schedulercomputation()
Scheduler intended for computational work.
This can be used for event-loops, processing callbacks and other computational work.
Do not perform IO-bound work on this scheduler. Use io() instead.
Unhandled errors will be delivered to the scheduler Thread's Thread.UncaughtExceptionHandler.
Scheduler meant for computation-bound work
public static Schedulerio()
Scheduler intended for IO-bound work.
The implementation is backed by an Executor thread-pool that will grow as needed.
This can be used for asynchronously performing blocking IO.
Do not perform computational work on this scheduler. Use computation() instead.
Unhandled errors will be delivered to the scheduler Thread's Thread.UncaughtExceptionHandler.
Scheduler meant for IO-bound work
public static TestSchedulertest()
TestScheduler, which is useful for debugging. It allows you to test schedules of events by manually advancing the clock at whatever pace you choose.
TestScheduler meant for debugging