Reactor Core 3.6.0 · reactor.core.scheduler.WorkerTask

A runnable task for Scheduler Workers that are time-capable (implementing a relevant schedule(delay) and schedulePeriodically(period) methods). Unlike the one in DelegateServiceScheduler, this runnable doesn't expose the ability to cancel inner task when interrupted.

Field Summary

Modifier and Type	Field and Description
pack-priv static final Future<Void>	ASYNC_CANCELLED marker that the Worker was cancelled from another thread, making it safe to interrupt the Future task.
pack-priv static final Disposable.Composite	DISPOSED marker that the Worker was disposed and the parent got notified
pack-priv static final Disposable.Composite	DONE marker that the Worker has completed, for the PARENT field
pack-priv static final Future<Void>	FINISHED marker that the Worker has completed, for the FUTURE field
pack-priv volatile Future<?>	future
pack-priv static final AtomicReferenceFieldUpdater<WorkerTask, Future<V>>	FUTURE
pack-priv volatile Disposable.Composite	parent
pack-priv static final AtomicReferenceFieldUpdater<WorkerTask, Disposable.Composite>	PARENT
pack-priv static final Future<Void>	SYNC_CANCELLED marker that the Worker was cancelled from the same thread (ie.
pack-priv final Runnable	task
pack-priv volatile Thread	thread
pack-priv static final AtomicReferenceFieldUpdater<WorkerTask, Thread>	THREAD

Constructor Summary

Access	Constructor and Description
pack-priv	WorkerTask(Runnable task, Disposable.Composite parent)

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

ASYNC_CANCELLED	back to summary
pack-priv static final Future<Void> ASYNC_CANCELLED marker that the Worker was cancelled from another thread, making it safe to interrupt the Future task.

DISPOSED	back to summary
pack-priv static final Disposable.Composite DISPOSED marker that the Worker was disposed and the parent got notified

DONE	back to summary
pack-priv static final Disposable.Composite DONE marker that the Worker has completed, for the PARENT field

FINISHED	back to summary
pack-priv static final Future<Void> FINISHED marker that the Worker has completed, for the FUTURE field

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

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

parent	back to summary
pack-priv volatile Disposable.Composite parent

PARENT	back to summary
pack-priv static final AtomicReferenceFieldUpdater<WorkerTask, Disposable.Composite> PARENT

SYNC_CANCELLED	back to summary
pack-priv static final Future<Void> SYNC_CANCELLED marker that the Worker was cancelled from the same thread (ie. within call()/run()), which means setFuture might race: we avoid interrupting the Future in this case.

task	back to summary
pack-priv final Runnable task

thread	back to summary
pack-priv volatile Thread thread

THREAD	back to summary
pack-priv static final AtomicReferenceFieldUpdater<WorkerTask, Thread> THREAD

Constructor Detail

WorkerTask	back to summary
pack-priv WorkerTask(Runnable task, Disposable.Composite parent)

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