Reactor Core 3.6.0 · reactor.core.scheduler.PeriodicSchedulerTask

Field Summary

Modifier and Type	Field and Description
pack-priv static final Future<Void>	CANCELLED
pack-priv volatile Future<?>	future
pack-priv static final AtomicReferenceFieldUpdater<PeriodicSchedulerTask, Future<V>>	FUTURE
pack-priv final Runnable	task
pack-priv Thread	thread

Constructor Summary

Access	Constructor and Description
pack-priv	PeriodicSchedulerTask(Runnable task)

Method Summary

Modifier and Type	Method 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.
public void	run() Implements java.lang.Runnable.run. Runs this operation.
pack-priv void	setFuture(Future<?> f)

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

CANCELLED	back to summary
pack-priv static final Future<Void> CANCELLED

future	back to summary
pack-priv volatile Future<?> future

FUTURE	back to summary
pack-priv static final AtomicReferenceFieldUpdater<PeriodicSchedulerTask, Future<V>> FUTURE

task	back to summary
pack-priv final Runnable task

thread	back to summary
pack-priv Thread thread

Constructor Detail

PeriodicSchedulerTask	back to summary
pack-priv PeriodicSchedulerTask(Runnable task)

Method Detail

call	back 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

call

back 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

dispose	back 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

dispose

back 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

isDisposed	back 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

isDisposed

back 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