Class ScheduledDirectPeriodicTask

java.lang.Object

java.util.concurrent.atomic.AtomicReference<Future<?>>

io.reactivex.rxjava3.internal.schedulers.AbstractDirectTask

io.reactivex.rxjava3.internal.schedulers.ScheduledDirectPeriodicTask

All Implemented Interfaces:

Disposable, SchedulerRunnableIntrospection, Serializable, Runnable

public final class ScheduledDirectPeriodicTask
extends AbstractDirectTask
implements Runnable

A Callable to be submitted to an ExecutorService that runs a Runnable action periodically and manages completion/cancellation.

Since:

2.0.8

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
private static final long	serialVersionUID

Fields inherited from class AbstractDirectTask

DISPOSED, FINISHED, interruptOnCancel, runnable, runner

Constructor Summary

Constructors

Constructor	Description
ScheduledDirectPeriodicTask(Runnable runnable, boolean interruptOnCancel)

Method Summary

Modifier and Type	Method	Description
void	run()

Methods inherited from class AbstractDirectTask

dispose, getWrappedRunnable, isDisposed, setFuture, toString

Methods inherited from class AtomicReference

accumulateAndGet, compareAndExchange, compareAndExchangeAcquire, compareAndExchangeRelease, compareAndSet, get, getAcquire, getAndAccumulate, getAndSet, getAndUpdate, getOpaque, getPlain, lazySet, 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

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

Constructor Details

ScheduledDirectPeriodicTask

public ScheduledDirectPeriodicTask(Runnable runnable,
 boolean interruptOnCancel)

Method Details

run

public void run()

Specified by:

run in interface Runnable