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

pack-priv final Class InstantPeriodicTask

extends Object
implements Callable<Void>, Disposable
Class Inheritance
All Implemented Interfaces
io.reactivex.rxjava3.disposables.Disposable, java.util.concurrent.Callable
Imports
java.util.concurrent.*, java.util.concurrent.atomic.AtomicReference, io.reactivex.rxjava3.disposables.Disposable, io.reactivex.rxjava3.internal.functions.Functions, io.reactivex.rxjava3.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.rxjava3.disposables.Disposable.dispose.

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

Implements io.reactivex.rxjava3.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()

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
disposeback to summary
public void dispose()

Implements io.reactivex.rxjava3.disposables.Disposable.dispose.

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

Dispose the resource, the operation should be idempotent.

Annotations
@Override
isDisposedback to summary
public boolean isDisposed()

Implements io.reactivex.rxjava3.disposables.Disposable.isDisposed.

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