Top Interfaces Classes

[default module]

Package io.reactivex.rxjava3.internal.schedulers

Interface Summary

Modifier and Type	Interface and Description
public interface	NonBlockingThread Marker interface to indicate blocking is not recommended while running on a Scheduler with a thread type implementing it.
public interface	SchedulerMultiWorkerSupport Allows retrieving multiple workers from the implementing `io.reactivex.rxjava3.core.Scheduler` in a way that when asking for at most the parallelism level of the Scheduler, those `io.reactivex.rxjava3.core.Scheduler.Worker` instances will be running with different backing threads.

Class Summary

Modifier and Type	Class and Description
pack-priv abstract class	AbstractDirectTask Base functionality for direct tasks that manage a runnable and cancellation/completion.
public class	ComputationScheduler Holds a fixed pool of worker threads and assigns them to requested Scheduler.Workers in a round-robin fashion.
pack-priv class	DisposeOnCancel Implements the Future interface and calls dispose() on cancel() but the other methods are not implemented.
public class	ExecutorScheduler Wraps an Executor and provides the Scheduler API over it.
public class	ImmediateThinScheduler A Scheduler partially implementing the API by allowing only non-delayed, non-periodic task execution on the current thread immediately.
pack-priv class	InstantPeriodicTask Wrapper for a regular task that gets immediately rescheduled when the task completed.
public class	IoScheduler Scheduler that creates and caches a set of thread pools and reuses them if possible.
public class	NewThreadScheduler Schedules work on a new thread.
public class	NewThreadWorker Base class that manages a single-threaded ScheduledExecutorService as a worker but doesn't perform task-tracking operations.
public class	RxThreadFactory A ThreadFactory that counts how many threads have been created and given a prefix, sets the created Thread's name to `prefix-count`.
public class	ScheduledDirectPeriodicTask A Callable to be submitted to an ExecutorService that runs a Runnable action periodically and manages completion/cancellation.
public class	ScheduledDirectTask A Callable to be submitted to an ExecutorService that runs a Runnable action and manages completion/cancellation.
public class	ScheduledRunnable
public class	SchedulerPoolFactory Manages the creating of ScheduledExecutorServices and sets up purging.
public class	SchedulerWhen Allows the use of operators for controlling the timing around when actions scheduled on workers are actually done.
public class	SingleScheduler A scheduler with a shared, single threaded underlying ScheduledExecutorService.
public class	TrampolineScheduler Schedules work on the current thread but does not execute immediately.