Interface | Description |
---|---|
NonBlockingThread |
Marker interface to indicate blocking is not recommended while running
on a Scheduler with a thread type implementing it.
|
SchedulerMultiWorkerSupport |
Allows retrieving multiple workers from the implementing
Scheduler in a way that when asking for
at most the parallelism level of the Scheduler, those
Scheduler.Worker instances will be running
with different backing threads. |
SchedulerMultiWorkerSupport.WorkerCallback |
The callback interface for the
SchedulerMultiWorkerSupport.createWorkers(int, WorkerCallback)
method. |
Class | Description |
---|---|
ComputationScheduler |
Holds a fixed pool of worker threads and assigns them
to requested Scheduler.Workers in a round-robin fashion.
|
ExecutorScheduler |
Wraps an Executor and provides the Scheduler API over it.
|
ExecutorScheduler.ExecutorWorker | |
ImmediateThinScheduler |
A Scheduler partially implementing the API by allowing only non-delayed, non-periodic
task execution on the current thread immediately.
|
IoScheduler |
Scheduler that creates and caches a set of thread pools and reuses them if possible.
|
NewThreadScheduler |
Schedules work on a new thread.
|
NewThreadWorker |
Base class that manages a single-threaded ScheduledExecutorService as a
worker but doesn't perform task-tracking operations.
|
RxThreadFactory |
A ThreadFactory that counts how many threads have been created and given a prefix,
sets the created Thread's name to
prefix-count . |
ScheduledDirectPeriodicTask |
A Callable to be submitted to an ExecutorService that runs a Runnable
action periodically and manages completion/cancellation.
|
ScheduledDirectTask |
A Callable to be submitted to an ExecutorService that runs a Runnable
action and manages completion/cancellation.
|
ScheduledRunnable | |
SchedulerPoolFactory |
Manages the creating of ScheduledExecutorServices and sets up purging.
|
SchedulerWhen |
Allows the use of operators for controlling the timing around when actions
scheduled on workers are actually done.
|
SingleScheduler |
A scheduler with a shared, single threaded underlying ScheduledExecutorService.
|
TrampolineScheduler |
Schedules work on the current thread but does not execute immediately.
|
Copyright © 2019. All rights reserved.