Package io.reactivex.rxjava3.internal.schedulers
package io.reactivex.rxjava3.internal.schedulers
-
ClassDescriptionBase functionality for direct tasks that manage a runnable and cancellation/completion.Holds a fixed pool of worker threads and assigns them to requested Scheduler.Workers in a round-robin fashion.Implements the Future interface and calls dispose() on cancel() but the other methods are not implemented.Wraps an Executor and provides the Scheduler API over it.Wrapper for a
Runnable
with additional logic for handling interruption on a shared thread, similar to how Java Executors do it.A Scheduler partially implementing the API by allowing only non-delayed, non-periodic task execution on the current thread immediately.Wrapper for a regular task that gets immediately rescheduled when the task completed.Scheduler that creates and caches a set of thread pools and reuses them if possible.Schedules work on a new thread.Base class that manages a single-threaded ScheduledExecutorService as a worker but doesn't perform task-tracking operations.Marker interface to indicate blocking is not recommended while running on a Scheduler with a thread type implementing it.A ThreadFactory that counts how many threads have been created and given a prefix, sets the created Thread's name toprefix-count
.A Callable to be submitted to an ExecutorService that runs a Runnable action periodically and manages completion/cancellation.A Callable to be submitted to an ExecutorService that runs a Runnable action and manages completion/cancellation.Allows retrieving multiple workers from the implementingScheduler
in a way that when asking for at most the parallelism level of the Scheduler, thoseScheduler.Worker
instances will be running with different backing threads.The callback interface for theSchedulerMultiWorkerSupport.createWorkers(int, WorkerCallback)
method.Manages the creating of ScheduledExecutorServices and sets up purging.Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.A scheduler with a shared, single threaded underlying ScheduledExecutorService.Schedules work on the current thread but does not execute immediately.