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

pack-priv abstract Class AbstractDirectTask

extends AtomicReference<Future<?>>
implements Disposable, SchedulerRunnableIntrospection
Class Inheritance
All Implemented Interfaces
io.reactivex.schedulers.SchedulerRunnableIntrospection, io.reactivex.disposables.Disposable
Known Direct Subclasses
io.reactivex.internal.schedulers.ScheduledDirectPeriodicTask, io.reactivex.internal.schedulers.ScheduledDirectTask
Imports
java.util.concurrent.*, java.util.concurrent.atomic.AtomicReference, io.reactivex.disposables.Disposable, io.reactivex.internal.functions.Functions, io.reactivex.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 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)

Method Summary

Modifier and TypeMethod and Description
public final void
dispose()

Implements io.reactivex.disposables.Disposable.dispose.

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

Implements io.reactivex.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable.

Returns the wrapped action.
public final boolean
isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

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

Inherited from java.util.concurrent.atomic.AtomicReference:
accumulateAndGetcompareAndExchangecompareAndExchangeAcquirecompareAndExchangeReleasecompareAndSetgetgetAcquiregetAndAccumulategetAndSetgetAndUpdategetOpaquegetPlainlazySetsetsetOpaquesetPlainsetReleasetoStringupdateAndGetweakCompareAndSetweakCompareAndSetAcquireweakCompareAndSetPlainweakCompareAndSetReleaseweakCompareAndSetVolatile

Field Detail

DISPOSEDback to summary
protected static final FutureTask<Void> DISPOSED
FINISHEDback to summary
protected static final FutureTask<Void> FINISHED
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)

Method Detail

disposeback to summary
public final void dispose()

Implements io.reactivex.disposables.Disposable.dispose.

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

Dispose the resource, the operation should be idempotent.

Annotations
@Override
getWrappedRunnableback to summary
public Runnable getWrappedRunnable()

Implements io.reactivex.schedulers.SchedulerRunnableIntrospection.getWrappedRunnable.

Doc from io.reactivex.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.disposables.Disposable.isDisposed.

Doc from io.reactivex.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)