Class ScheduledRunnable

java.lang.Object

java.util.concurrent.atomic.AtomicReferenceArray<Object>

io.reactivex.rxjava3.internal.schedulers.ScheduledRunnable

All Implemented Interfaces:

Disposable, Serializable, Runnable, Callable<Object>

public final class ScheduledRunnable
extends AtomicReferenceArray<Object>
implements Runnable, Callable<Object>, Disposable

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ScheduledRunnable(Runnable actual, DisposableContainer parent)	Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent.
ScheduledRunnable(Runnable actual, DisposableContainer parent, boolean interruptOnCancel)	Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent.

Method Summary

Modifier and Type	Method	Description
Object	call()
void	dispose()	Dispose the resource, the operation should be idempotent.
boolean	isDisposed()	Returns true if this resource has been disposed.
void	run()
void	setFuture(Future<?> f)
String	toString()

Methods inherited from class AtomicReferenceArray

accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, length, set, setOpaque, setPlain, setRelease, updateAndGet, weakCompareAndSet, weakCompareAndSetAcquire, weakCompareAndSetPlain, weakCompareAndSetRelease, weakCompareAndSetVolatile

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ScheduledRunnable

public ScheduledRunnable(Runnable actual,
 DisposableContainer parent)

Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent. The underlying future will be interrupted if the task is disposed asynchronously.

Parameters:

actual - the runnable to wrap, not-null (not verified)

parent - the parent tracking container or null if none

ScheduledRunnable

public ScheduledRunnable(Runnable actual,
 DisposableContainer parent,
 boolean interruptOnCancel)

Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent.

Parameters:

actual - the runnable to wrap, not-null (not verified)

parent - the parent tracking container or null if none

interruptOnCancel - if true, the underlying future will be interrupted when disposing this task from a different thread than it is running on.

Method Details

call

public Object call()

Specified by:

call in interface Callable<Object>

run

public void run()

Specified by:

run in interface Runnable

setFuture

public void setFuture(Future<?> f)

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable

isDisposed

public boolean isDisposed()

Description copied from interface: Disposable

Returns true if this resource has been disposed.

Specified by:

isDisposed in interface Disposable

Returns:

true if this resource has been disposed

toString

public String toString()

Overrides:

toString in class AtomicReferenceArray<Object>