Class NewThreadScheduler

java.lang.Object

io.reactivex.rxjava3.core.Scheduler

io.reactivex.rxjava3.internal.schedulers.NewThreadScheduler

public final class NewThreadScheduler
extends Scheduler

Schedules work on a new thread.

Nested Class Summary

Nested classes/interfaces inherited from class Scheduler

Scheduler.Worker

Field Summary

Fields

Modifier and Type	Field	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
(package private) final ThreadFactory	threadFactory

Constructor Summary

Constructors

Constructor	Description
NewThreadScheduler()
NewThreadScheduler(ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method	Description
@NonNull Scheduler.Worker	createWorker()	Retrieves or creates a new Scheduler.Worker that represents sequential execution of actions.

Methods inherited from class Scheduler

clockDriftTolerance, now, scheduleDirect, scheduleDirect, schedulePeriodicallyDirect, shutdown, start, when

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

threadFactory

final ThreadFactory threadFactory

THREAD_NAME_PREFIX

private static final String THREAD_NAME_PREFIX

See Also:

• Constant Field Values

THREAD_FACTORY

private static final RxThreadFactory THREAD_FACTORY

KEY_NEWTHREAD_PRIORITY

private static final String KEY_NEWTHREAD_PRIORITY

The name of the system property for setting the thread priority for this Scheduler.

See Also:

• Constant Field Values

Constructor Details

NewThreadScheduler

public NewThreadScheduler()

NewThreadScheduler

public NewThreadScheduler(ThreadFactory threadFactory)

Method Details

createWorker

@NonNull
public @NonNull Scheduler.Worker createWorker()

Description copied from class: Scheduler

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 Disposable.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.

Specified by:

createWorker in class Scheduler

Returns:

a Worker representing a serial queue of actions to be executed