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

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

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