Package io.reactivex.rxjava3.internal.schedulers

Class InstantPeriodicTask

java.lang.Object

io.reactivex.rxjava3.internal.schedulers.InstantPeriodicTask

All Implemented Interfaces:

Disposable, Callable<Void>

final class InstantPeriodicTask
extends Object
implements Callable<Void>, Disposable

Wrapper for a regular task that gets immediately rescheduled when the task completed.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final FutureTask<Void>	CANCELLED
(package private) final ExecutorService	executor
(package private) final AtomicReference<Future<?>>	first
(package private) final AtomicReference<Future<?>>	rest
(package private) Thread	runner
(package private) final Runnable	task

Constructor Summary

Constructors

Constructor	Description
InstantPeriodicTask(Runnable task, ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
Void	call()
void	dispose()	Dispose the resource, the operation should be idempotent.
boolean	isDisposed()	Returns true if this resource has been disposed.
(package private) void	setFirst(Future<?> f)
(package private) void	setRest(Future<?> f)

Methods inherited from class java.lang.Object

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

Field Details

task

final Runnable task

rest

final AtomicReference<Future<?>> rest

first

final AtomicReference<Future<?>> first

executor

final ExecutorService executor

runner

Thread runner

CANCELLED

static final FutureTask<Void> CANCELLED

Constructor Details

InstantPeriodicTask

InstantPeriodicTask(Runnable task,
 ExecutorService executor)

Method Details

call

public Void call()

Specified by:

call in interface Callable<Void>

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

setFirst

void setFirst(Future<?> f)

setRest

void setRest(Future<?> f)