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.
  • Field Details

    • threadFactory

      final ThreadFactory threadFactory
    • THREAD_NAME_PREFIX

      private static final String THREAD_NAME_PREFIX
      See Also:
    • 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:
  • 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