Class AbstractDirectTask

java.lang.Object
java.util.concurrent.atomic.AtomicReference<Future<?>>
io.reactivex.rxjava3.internal.schedulers.AbstractDirectTask
All Implemented Interfaces:
Disposable, SchedulerRunnableIntrospection, Serializable
Direct Known Subclasses:
ScheduledDirectPeriodicTask, ScheduledDirectTask

abstract class AbstractDirectTask extends AtomicReference<Future<?>> implements Disposable, SchedulerRunnableIntrospection
Base functionality for direct tasks that manage a runnable and cancellation/completion.
Since:
2.0.8
  • Field Details

    • serialVersionUID

      private static final long serialVersionUID
      See Also:
    • runnable

      protected final Runnable runnable
    • interruptOnCancel

      protected final boolean interruptOnCancel
    • runner

      protected Thread runner
    • FINISHED

      protected static final FutureTask<Void> FINISHED
    • DISPOSED

      protected static final FutureTask<Void> DISPOSED
  • Constructor Details

    • AbstractDirectTask

      AbstractDirectTask(Runnable runnable, boolean interruptOnCancel)
  • Method Details