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

pack-priv final Class InstantPeriodicTask

extends Object
implements Callable<Void>, Disposable
Class Inheritance
All Implemented Interfaces
io.reactivex.disposables.Disposable, java.util.concurrent.Callable
Imports
java.util.concurrent.*, java.util.concurrent.atomic.AtomicReference, io.reactivex.disposables.Disposable, io.reactivex.internal.functions.Functions, io.reactivex.plugins.RxJavaPlugins
Wrapper for a regular task that gets immediately rescheduled when the task completed.

Field Summary

Modifier and TypeField and Description
pack-priv static final FutureTask<Void>
CANCELLED

pack-priv final ExecutorService
executor

pack-priv final AtomicReference<Future<?>>
first

pack-priv final AtomicReference<Future<?>>
rest

pack-priv Thread
runner

pack-priv final Runnable
task

Constructor Summary

AccessConstructor and Description
pack-priv
InstantPeriodicTask(Runnable task, ExecutorService executor)

Method Summary

Modifier and TypeMethod and Description
public Void
call()

Implements java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.
public void
dispose()

Implements io.reactivex.disposables.Disposable.dispose.

Dispose the resource, the operation should be idempotent.
public boolean
isDisposed()

Implements io.reactivex.disposables.Disposable.isDisposed.

Returns true if this resource has been disposed.
pack-priv void
setFirst(Future<?> f)

pack-priv void
setRest(Future<?> f)

Inherited from java.lang.Object:
cloneequalsfinalizegetClasshashCodenotifynotifyAlltoStringwaitwaitwait

Field Detail

CANCELLEDback to summary
pack-priv static final FutureTask<Void> CANCELLED
executorback to summary
pack-priv final ExecutorService executor
firstback to summary
pack-priv final AtomicReference<Future<?>> first
restback to summary
pack-priv final AtomicReference<Future<?>> rest
runnerback to summary
pack-priv Thread runner
taskback to summary
pack-priv final Runnable task

Constructor Detail

InstantPeriodicTaskback to summary
pack-priv InstantPeriodicTask(Runnable task, ExecutorService executor)

Method Detail

callback to summary
public Void call() throws Exception

Implements java.util.concurrent.Callable.call.

Doc from java.util.concurrent.Callable.call.

Computes a result, or throws an exception if unable to do so.

Returns:Void

computed result

Annotations
@Override
Exceptions
Exception:
if unable to compute a result
disposeback to summary
public 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
isDisposedback to summary
public 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
setFirstback to summary
pack-priv void setFirst(Future<?> f)
setRestback to summary
pack-priv void setRest(Future<?> f)