RxJava 3 3.1.8 · io.reactivex.rxjava3.internal.schedulers.NewThreadScheduler

Field Summary

Modifier and Type	Field and Description
private static final String	KEY_NEWTHREAD_PRIORITY The name of the system property for setting the thread priority for this Scheduler.
private static final RxThreadFactory	THREAD_FACTORY
private static final String	THREAD_NAME_PREFIX
pack-priv final ThreadFactory	threadFactory

Constructor Summary

Access	Constructor and Description
public	NewThreadScheduler()
public	NewThreadScheduler(ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
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.

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

Field Detail

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

THREAD_FACTORY	back to summary
private static final RxThreadFactory 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

NewThreadScheduler	back to summary
public NewThreadScheduler()

NewThreadScheduler	back to summary
public NewThreadScheduler(ThreadFactory threadFactory)

Method Detail

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