Top Description Fields Constructors Methods
reactor.core.scheduler

pack-priv final Class InstantPeriodicWorkerTask

extends Object
implements Disposable, Callable<Void>
Class Inheritance
All Implemented Interfaces
java.util.concurrent.Callable, reactor.core.Disposable
Imports
java.util.concurrent.Callable, .ExecutorService, .Future, .FutureTask, java.util.concurrent.atomic.AtomicReferenceFieldUpdater, reactor.core.Disposable, reactor.util.annotation.Nullable
A runnable task for Scheduler Workers that can run periodically

Field Summary

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

pack-priv static final Disposable.Composite
DISPOSED

pack-priv final ExecutorService
executor

pack-priv volatile Future<?>
first

pack-priv static final AtomicReferenceFieldUpdater<InstantPeriodicWorkerTask, Future<V>>
FIRST

pack-priv volatile Disposable.Composite
parent

pack-priv static final AtomicReferenceFieldUpdater<InstantPeriodicWorkerTask, Disposable.Composite>
PARENT

pack-priv volatile Future<?>
rest

pack-priv static final AtomicReferenceFieldUpdater<InstantPeriodicWorkerTask, Future<V>>
REST

pack-priv final Runnable
task

pack-priv Thread
thread

Constructor Summary

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

pack-priv
InstantPeriodicWorkerTask(Runnable task, ExecutorService executor, Disposable.Composite parent)

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 reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.
public boolean
isDisposed()

Overrides default reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is 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 Future<Void> CANCELLED
DISPOSEDback to summary
pack-priv static final Disposable.Composite DISPOSED
executorback to summary
pack-priv final ExecutorService executor
firstback to summary
pack-priv volatile Future<?> first
FIRSTback to summary
pack-priv static final AtomicReferenceFieldUpdater<InstantPeriodicWorkerTask, Future<V>> FIRST
parentback to summary
pack-priv volatile Disposable.Composite parent
PARENTback to summary
pack-priv static final AtomicReferenceFieldUpdater<InstantPeriodicWorkerTask, Disposable.Composite> PARENT
restback to summary
pack-priv volatile Future<?> rest
RESTback to summary
pack-priv static final AtomicReferenceFieldUpdater<InstantPeriodicWorkerTask, Future<V>> REST
taskback to summary
pack-priv final Runnable task
threadback to summary
pack-priv Thread thread

Constructor Detail

InstantPeriodicWorkerTaskback to summary
pack-priv InstantPeriodicWorkerTask(Runnable task, ExecutorService executor)
InstantPeriodicWorkerTaskback to summary
pack-priv InstantPeriodicWorkerTask(Runnable task, ExecutorService executor, Disposable.Composite parent)

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

Implements reactor.core.Disposable.dispose.

Doc from reactor.core.Disposable.dispose.

Cancel or dispose the underlying task or resource.

Implementations are required to make this method idempotent.

Annotations
@Override
isDisposedback to summary
public boolean isDisposed()

Overrides default reactor.core.Disposable.isDisposed.

Doc from reactor.core.Disposable.isDisposed.

Optionally return true when the resource or task is disposed.

Implementations are not required to track disposition and as such may never return true even when disposed. However, they MUST only return true when there's a guarantee the resource or task is disposed.

Returns:boolean

true when there's a guarantee the resource or task is disposed.

Annotations
@Override
setFirstback to summary
pack-priv void setFirst(Future<?> f)
setRestback to summary
pack-priv void setRest(Future<?> f)