hu.akarnokd.rxjava2.internal.schedulers

Class ScheduledRunnable

java.lang.Object

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

hu.akarnokd.rxjava2.internal.schedulers.ScheduledRunnable

All Implemented Interfaces:

Disposable, java.io.Serializable, java.lang.Runnable

public final class ScheduledRunnable
extends java.util.concurrent.atomic.AtomicReferenceArray<java.lang.Object>
implements java.lang.Runnable, Disposable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ScheduledRunnable(java.lang.Runnable actual, CompositeResource<Disposable> parent) Creates a ScheduledRunnable by wrapping the given action and setting up the optional parent.

Method Summary

Modifier and Type	Method and Description
void	dispose() Dispose the resource, the operation should be idempotent.
void	run()
void	setFuture(java.util.concurrent.Future<?> f)
boolean	wasScheduled() Returns true if this ScheduledRunnable has been scheduled.

Methods inherited from class java.util.concurrent.atomic.AtomicReferenceArray

accumulateAndGet, compareAndSet, get, getAndAccumulate, getAndSet, getAndUpdate, lazySet, length, set, toString, updateAndGet, weakCompareAndSet

Methods inherited from class java.lang.Object

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

Constructor Detail

ScheduledRunnable

public ScheduledRunnable(java.lang.Runnable actual,
                         CompositeResource<Disposable> parent)

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

Method Detail

run

public void run()

Specified by:

run in interface java.lang.Runnable

setFuture

public void setFuture(java.util.concurrent.Future<?> f)

wasScheduled

public boolean wasScheduled()

Returns true if this ScheduledRunnable has been scheduled.

Returns:

true if this ScheduledRunnable has been scheduled.

dispose

public void dispose()

Description copied from interface: Disposable

Dispose the resource, the operation should be idempotent.

Specified by:

dispose in interface Disposable