AbstractDirectTask |
Base functionality for direct tasks that manage a runnable and cancellation/completion.
|
ComputationScheduler |
Holds a fixed pool of worker threads and assigns them
to requested Scheduler.Workers in a round-robin fashion.
|
ComputationScheduler.EventLoopWorker |
|
ComputationScheduler.FixedSchedulerPool |
|
ComputationScheduler.PoolWorker |
|
DisposeOnCancel |
Implements the Future interface and calls dispose() on cancel() but
the other methods are not implemented.
|
ExecutorScheduler |
Wraps an Executor and provides the Scheduler API over it.
|
ExecutorScheduler.DelayedRunnable |
|
ExecutorScheduler.ExecutorWorker |
|
ExecutorScheduler.ExecutorWorker.BooleanRunnable |
|
ExecutorScheduler.ExecutorWorker.InterruptibleRunnable |
Wrapper for a Runnable with additional logic for handling interruption on
a shared thread, similar to how Java Executors do it.
|
ExecutorScheduler.SingleHolder |
|
ImmediateThinScheduler |
A Scheduler partially implementing the API by allowing only non-delayed, non-periodic
task execution on the current thread immediately.
|
ImmediateThinScheduler.ImmediateThinWorker |
|
InstantPeriodicTask |
Wrapper for a regular task that gets immediately rescheduled when the task completed.
|
IoScheduler |
Scheduler that creates and caches a set of thread pools and reuses them if possible.
|
IoScheduler.CachedWorkerPool |
|
IoScheduler.EventLoopWorker |
|
IoScheduler.ThreadWorker |
|
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 .
|
RxThreadFactory.RxCustomThread |
|
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.
|
SchedulerPoolFactory.SystemPropertyAccessor |
|
SchedulerWhen |
Allows the use of operators for controlling the timing around when actions
scheduled on workers are actually done.
|
SchedulerWhen.CreateWorkerFunction |
|
SchedulerWhen.DelayedAction |
|
SchedulerWhen.ImmediateAction |
|
SchedulerWhen.OnCompletedAction |
|
SchedulerWhen.QueueWorker |
|
SchedulerWhen.ScheduledAction |
|
SchedulerWhen.SubscribedDisposable |
|
SingleScheduler |
A scheduler with a shared, single threaded underlying ScheduledExecutorService.
|
SingleScheduler.ScheduledWorker |
|
TrampolineScheduler |
Schedules work on the current thread but does not execute immediately.
|
TrampolineScheduler.SleepingRunnable |
|
TrampolineScheduler.TimedRunnable |
|
TrampolineScheduler.TrampolineWorker |
|