org.springframework.util.concurrent

Class ListenableFutureCallbackRegistry<T>

java.lang.Object

org.springframework.util.concurrent.ListenableFutureCallbackRegistry<T>

public class ListenableFutureCallbackRegistry<T>
extends java.lang.Object

Registry for ListenableFutureCallback instances.

Inspired by com.google.common.util.concurrent.ExecutionList.

Since:

4.0

Author:

Arjen Poutsma, Sebastien Deleuze

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	ListenableFutureCallbackRegistry.State

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.Queue<FailureCallback>	failureCallbacks
private java.lang.Object	mutex
private java.lang.Object	result
private ListenableFutureCallbackRegistry.State	state
private java.util.Queue<SuccessCallback<? super T>>	successCallbacks

Constructor Summary

Constructors

Constructor and Description
ListenableFutureCallbackRegistry()

Method Summary

Modifier and Type	Method and Description
void	addCallback(ListenableFutureCallback<? super T> callback) Add the given callback to this registry.
void	addFailureCallback(FailureCallback callback) Add the given failure callback to this registry.
void	addSuccessCallback(SuccessCallback<? super T> callback) Add the given success callback to this registry.
void	failure(java.lang.Throwable ex) Trigger a FailureCallback.onFailure(Throwable) call on all added callbacks with the given Throwable.
void	success(T result) Trigger a SuccessCallback.onSuccess(Object) call on all added callbacks with the given result.

Methods inherited from class java.lang.Object

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

Field Detail

successCallbacks

private final java.util.Queue<SuccessCallback<? super T>> successCallbacks

failureCallbacks

private final java.util.Queue<FailureCallback> failureCallbacks

state

private ListenableFutureCallbackRegistry.State state

result

private java.lang.Object result

mutex

private final java.lang.Object mutex

Constructor Detail

ListenableFutureCallbackRegistry

public ListenableFutureCallbackRegistry()

Method Detail

addCallback

public void addCallback(ListenableFutureCallback<? super T> callback)

Add the given callback to this registry.

Parameters:

callback - the callback to add

addSuccessCallback

public void addSuccessCallback(SuccessCallback<? super T> callback)

Add the given success callback to this registry.

Parameters:

callback - the success callback to add

Since:

4.1

addFailureCallback

public void addFailureCallback(FailureCallback callback)

Add the given failure callback to this registry.

Parameters:

callback - the failure callback to add

Since:

4.1

success

public void success(T result)

Trigger a SuccessCallback.onSuccess(Object) call on all added callbacks with the given result.

Parameters:

result - the result to trigger the callbacks with

failure

public void failure(java.lang.Throwable ex)

Trigger a FailureCallback.onFailure(Throwable) call on all added callbacks with the given Throwable.

Parameters:

ex - the exception to trigger the callbacks with