Top Description Fields Constructors Methods
io.reactivex.rxjava3.internal.schedulers

pack-priv abstract Class AbstractDirectTask

extends AtomicReference<Future<?>>
implements Disposable, SchedulerRunnableIntrospection
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.schedulers.SchedulerRunnableIntrospection, io.reactivex.rxjava3.disposables.Disposable
Known Direct Subclasses
io.reactivex.rxjava3.internal.schedulers.ScheduledDirectPeriodicTask, io.reactivex.rxjava3.internal.schedulers.ScheduledDirectTask
Imports
java.util.concurrent.*, java.util.concurrent.atomic.AtomicReference, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.internal.functions.Functions, io.reactivex.rxjava3.schedulers.SchedulerRunnableIntrospection
Base functionality for direct tasks that manage a runnable and cancellation/completion.
Since
2.0.8

Field Summary

Modifier and TypeField and Description
protected static final FutureTask<Void>
DISPOSED

protected static final FutureTask<Void>
FINISHED

protected final boolean
interruptOnCancel

protected final Runnable
runnable

protected Thread
runner

private static final long
serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Summary

AccessConstructor and Description
pack-priv
AbstractDirectTask(Runnable runnable, boolean interruptOnCancel)

Method Summary

Modifier and TypeMethod and Description
private void
cancelFuture(Future<?> future)

public final void
dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
public Runnable
getWrappedRunnable()

Implements io.reactivex.rxjava3.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable.

Returns the wrapped action.
public final boolean
isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
public final void
setFuture(Future<?> future)

public String
toString()

Overrides java.util.concurrent.atomic.AtomicReference.toString.

Returns the String representation of the current value.
Inherited from java.util.concurrent.atomic.AtomicReference:
accumulateAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetgetgetAcquiregetAndAccumulategetAndSetgetAndUpdategetOpaquegetPlainlazySetsetsetOpaquesetPlainsetReleaseupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

DISPOSEDback to summary
protected static final FutureTask<Void> DISPOSED
FINISHEDback to summary
protected static final FutureTask<Void> FINISHED
interruptOnCancelback to summary
protected final boolean interruptOnCancel
runnableback to summary
protected final Runnable runnable
runnerback to summary
protected Thread runner
serialVersionUIDback to summary
private static final long serialVersionUID

Hides java.util.concurrent.atomic.AtomicReference.serialVersionUID.

Constructor Detail

AbstractDirectTaskback to summary
pack-priv AbstractDirectTask(Runnable runnable, boolean interruptOnCancel)

Method Detail

cancelFutureback to summary
private void cancelFuture(Future<?> future)
disposeback to summary
public final void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

Doc from io.reactivex.rxjava3.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.

Annotations
@Override
getWrappedRunnableback to summary
public Runnable getWrappedRunnable()

Implements io.reactivex.rxjava3.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable.

Doc from io.reactivex.rxjava3.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable.

Returns the wrapped action.

Returns:Runnable

the wrapped action. Cannot be null.

Annotations
@Override
isDisposedback to summary
public final boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Doc from io.reactivex.rxjava3.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.

Returns:boolean

true if this resource has been disposed

Annotations
@Override
setFutureback to summary
public final void setFuture(Future<?> future)
toStringback to summary
public String toString()

Overrides java.util.concurrent.atomic.AtomicReference.toString.

Doc from java.util.concurrent.atomic.AtomicReference.toString.

Returns the String representation of the current value.

Returns:String

the String representation of the current value

Annotations
@Override