RxJava 2 2.2.21 · io.reactivex.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 Scheduler.Worker	createWorker() Implements abstract io.reactivex.Scheduler.createWorker. Retrieves or creates a new `Scheduler.Worker` that represents sequential execution of actions.

Inherited from io.reactivex.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 Scheduler.Worker createWorker() Implements abstract io.reactivex.Scheduler.createWorker. Doc from io.reactivex.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:Scheduler.Worker a Worker representing a serial queue of actions to be executed Annotations @NonNull @Override

public Scheduler.Worker createWorker()

Implements abstract io.reactivex.Scheduler.createWorker.

Doc from io.reactivex.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:Scheduler.Worker

a Worker representing a serial queue of actions to be executed

Annotations