Modifier and Type	Class and Description
pack-priv static class	SingleScheduler.ScheduledWorker

Field Summary

Modifier and Type	Field and Description
pack-priv final AtomicReference<ScheduledExecutorService>	executor
private static final String	KEY_SINGLE_PRIORITY The name of the system property for setting the thread priority for this Scheduler.
pack-priv static final ScheduledExecutorService	SHUTDOWN
pack-priv static final RxThreadFactory	SINGLE_THREAD_FACTORY
private static final String	THREAD_NAME_PREFIX
pack-priv final ThreadFactory	threadFactory

Constructor Summary

Access	Constructor and Description
public	SingleScheduler()
public	SingleScheduler(ThreadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null. threadFactory) Constructs a SingleScheduler with the given ThreadFactory and prepares the single scheduler thread.

Method Summary

Modifier and Type	Method and Description
pack-priv static ScheduledExecutorService	createExecutor(ThreadFactory threadFactory)
public @NonNull Scheduler.Worker	createWorker() Implements abstract io.reactivex.rxjava3.core.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents sequential execution of actions.
public @NonNull Disposable	scheduleDirect(@NonNull Runnable run, long delay, TimeUnit unit)
public @NonNull Disposable	schedulePeriodicallyDirect(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit)
public void	shutdown() Overrides io.reactivex.rxjava3.core.Scheduler.shutdown. Instructs the Scheduler instance to stop threads, stop accepting tasks on any outstanding `Worker` instances and clean up any associated resources with this Scheduler.
public void	start() Overrides io.reactivex.rxjava3.core.Scheduler.start. Allows the Scheduler instance to start threads and accept tasks on them.

Inherited from io.reactivex.rxjava3.core.Scheduler:: clockDriftTolerance now scheduleDirect scheduleDirect schedulePeriodicallyDirect when

Field Detail

executor	back to summary
pack-priv final AtomicReference<ScheduledExecutorService> executor

KEY_SINGLE_PRIORITY	back to summary
private static final String KEY_SINGLE_PRIORITY The name of the system property for setting the thread priority for this Scheduler.

SHUTDOWN	back to summary
pack-priv static final ScheduledExecutorService SHUTDOWN

SINGLE_THREAD_FACTORY	back to summary
pack-priv static final RxThreadFactory SINGLE_THREAD_FACTORY

THREAD_NAME_PREFIX	back to summary
private static final String THREAD_NAME_PREFIX

threadFactory	back to summary
pack-priv final ThreadFactory threadFactory

Constructor Detail

SingleScheduler	back to summary
public SingleScheduler()

SingleScheduler	back to summary
public SingleScheduler(ThreadFactory threadFactory) Constructs a SingleScheduler with the given ThreadFactory and prepares the single scheduler thread. Parameters threadFactory:ThreadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.

SingleScheduler

back to summary

public SingleScheduler(ThreadFactory threadFactory)

Constructs a SingleScheduler with the given ThreadFactory and prepares the single scheduler thread.

Parameters

threadFactory:ThreadFactory: thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.

Method Detail

createExecutor	back to summary
pack-priv static ScheduledExecutorService createExecutor(ThreadFactory threadFactory)

createWorker back to summary

createWorker	back to summary
public @NonNull Scheduler.Worker createWorker() Implements abstract io.reactivex.rxjava3.core.Scheduler.createWorker. Doc from io.reactivex.rxjava3.core.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents sequential execution of actions. When work is completed, the `Worker` instance should be released by calling `Scheduler.Worker#dispose()` to avoid potential resource leaks in the underlying task-execution scheme. Work on a `Scheduler.Worker` is guaranteed to be sequential and non-overlapping. Returns:@NonNull Scheduler.Worker a Worker representing a serial queue of actions to be executed Annotations @NonNull @Override

public @NonNull Scheduler.Worker createWorker()

Implements abstract io.reactivex.rxjava3.core.Scheduler.createWorker.

Doc from io.reactivex.rxjava3.core.Scheduler.createWorker.

Retrieves or creates a new Scheduler.Worker that represents sequential execution of actions.

When work is completed, the Worker instance should be released by calling Scheduler.Worker#dispose() to avoid potential resource leaks in the underlying task-execution scheme.

Work on a Scheduler.Worker is guaranteed to be sequential and non-overlapping.

Returns:@NonNull Scheduler.Worker

a Worker representing a serial queue of actions to be executed

Annotations

@NonNull
@Override

scheduleDirect	back to summary
public @NonNull Disposable scheduleDirect(@NonNull Runnable run, long delay, TimeUnit unit) Annotations @NonNull @Override

schedulePeriodicallyDirect	back to summary
public @NonNull Disposable schedulePeriodicallyDirect(@NonNull Runnable run, long initialDelay, long period, TimeUnit unit) Annotations @NonNull @Override

shutdown back to summary

shutdown	back to summary
public void shutdown() Overrides io.reactivex.rxjava3.core.Scheduler.shutdown. Doc from io.reactivex.rxjava3.core.Scheduler.shutdown. Instructs the Scheduler instance to stop threads, stop accepting tasks on any outstanding `Worker` instances and clean up any associated resources with this Scheduler. Implementations should make sure the call is idempotent, thread-safe and should not throw any `RuntimeException` if it doesn't support this functionality. Annotations @Override

public void shutdown()

Overrides io.reactivex.rxjava3.core.Scheduler.shutdown.

Doc from io.reactivex.rxjava3.core.Scheduler.shutdown.

Instructs the Scheduler instance to stop threads, stop accepting tasks on any outstanding Worker instances and clean up any associated resources with this Scheduler.

Implementations should make sure the call is idempotent, thread-safe and should not throw any RuntimeException if it doesn't support this functionality.

Annotations

@Override

start back to summary

start	back to summary
public void start() Overrides io.reactivex.rxjava3.core.Scheduler.start. Doc from io.reactivex.rxjava3.core.Scheduler.start. Allows the Scheduler instance to start threads and accept tasks on them. Implementations should make sure the call is idempotent, thread-safe and should not throw any `RuntimeException` if it doesn't support this functionality. Annotations @Override

public void start()

Overrides io.reactivex.rxjava3.core.Scheduler.start.

Doc from io.reactivex.rxjava3.core.Scheduler.start.

Allows the Scheduler instance to start threads and accept tasks on them.

Implementations should make sure the call is idempotent, thread-safe and should not throw any RuntimeException if it doesn't support this functionality.

Annotations

@Override

io.reactivex.rxjava3.internal.schedulers back to summary

pack-priv final Class SingleScheduler.ScheduledWorker

Class Inheritance

extends Worker

java.lang.Object
io.reactivex.rxjava3.core.Scheduler.Worker
io.reactivex.rxjava3.internal.schedulers.SingleScheduler.ScheduledWorker

Field Summary

Modifier and Type	Field and Description
pack-priv volatile boolean	disposed
pack-priv final ScheduledExecutorService	executor
pack-priv final CompositeDisposable	tasks

Constructor Summary

Access	Constructor and Description
pack-priv	ScheduledWorker(ScheduledExecutorService executor)

Method Summary

Modifier and Type	Method and Description
public void	dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent.
public boolean	isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed.
public @NonNull Disposable	schedule(@NonNull Runnable run, long delay, @NonNull TimeUnit unit)

Inherited from io.reactivex.rxjava3.core.Scheduler.Worker:: now schedule schedule schedulePeriodically

Field Detail

disposed	back to summary
pack-priv volatile boolean disposed

executor	back to summary
pack-priv final ScheduledExecutorService executor

tasks	back to summary
pack-priv final CompositeDisposable tasks

Constructor Detail

ScheduledWorker	back to summary
pack-priv ScheduledWorker(ScheduledExecutorService executor)

Method Detail

dispose	back to summary
public void dispose() Implements io.reactivex.rxjava3.disposables.Disposable.dispose. Doc from io.reactivex.rxjava3.disposables.Disposable.dispose. Dispose the resource, the operation should be idempotent. Annotations @Override

dispose

back to summary

public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations

@Override

isDisposed	back to summary
public boolean isDisposed() Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed. Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed. Returns true if this resource has been disposed. Returns:boolean true if this resource has been disposed Annotations @Override

isDisposed

back to summary

public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations