Package io.reactivex.rxjava3.internal.schedulers
package io.reactivex.rxjava3.internal.schedulers
-
ClassDescriptionHolds a fixed pool of worker threads and assigns them to requested Scheduler.Workers in a round-robin fashion.Wraps an Executor and provides the Scheduler API over it.A Scheduler partially implementing the API by allowing only non-delayed, non-periodic task execution on the current thread immediately.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 to
prefix-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 implementingSchedulerin a way that when asking for at most the parallelism level of the Scheduler, thoseScheduler.Workerinstances 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.