Class NewThreadScheduler
java.lang.Object
io.reactivex.rxjava3.core.Scheduler
io.reactivex.rxjava3.internal.schedulers.NewThreadScheduler
Schedules work on a new thread.
-
Nested Class Summary
Nested classes/interfaces inherited from class io.reactivex.rxjava3.core.Scheduler
Scheduler.Worker
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate static final String
The name of the system property for setting the thread priority for this Scheduler.private static final RxThreadFactory
private static final String
(package private) final ThreadFactory
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionRetrieves or creates a newScheduler.Worker
that represents sequential execution of actions.Methods inherited from class io.reactivex.rxjava3.core.Scheduler
clockDriftTolerance, now, scheduleDirect, scheduleDirect, schedulePeriodicallyDirect, shutdown, start, when
-
Field Details
-
threadFactory
-
THREAD_NAME_PREFIX
- See Also:
-
THREAD_FACTORY
-
KEY_NEWTHREAD_PRIORITY
The name of the system property for setting the thread priority for this Scheduler.- See Also:
-
-
Constructor Details
-
NewThreadScheduler
public NewThreadScheduler() -
NewThreadScheduler
-
-
Method Details
-
createWorker
Description copied from class:Scheduler
Retrieves or creates a newScheduler.Worker
that represents sequential execution of actions.When work is completed, the
Worker
instance should be released by callingDisposable.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 classScheduler
- Returns:
- a Worker representing a serial queue of actions to be executed
-