| 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 |
|