Class InstantPeriodicTask
java.lang.Object
io.reactivex.rxjava3.internal.schedulers.InstantPeriodicTask
- All Implemented Interfaces:
Disposable
,Callable<Void>
Wrapper for a regular task that gets immediately rescheduled when the task completed.
-
Field Summary
FieldsModifier and TypeFieldDescription(package private) static final FutureTask
<Void> (package private) final ExecutorService
(package private) final AtomicReference
<Future<?>> (package private) final AtomicReference
<Future<?>> (package private) Thread
(package private) final Runnable
-
Constructor Summary
Constructors -
Method Summary
-
Field Details
-
task
-
rest
-
first
-
executor
-
runner
Thread runner -
CANCELLED
-
-
Constructor Details
-
InstantPeriodicTask
InstantPeriodicTask(Runnable task, ExecutorService executor)
-
-
Method Details
-
call
-
dispose
public void dispose()Description copied from interface:Disposable
Dispose the resource, the operation should be idempotent.- Specified by:
dispose
in interfaceDisposable
-
isDisposed
public boolean isDisposed()Description copied from interface:Disposable
Returns true if this resource has been disposed.- Specified by:
isDisposed
in interfaceDisposable
- Returns:
- true if this resource has been disposed
-
setFirst
-
setRest
-