org.infinispan.commons.util.concurrent

Class NotifyingFutureImpl<T>

java.lang.Object

org.infinispan.commons.util.concurrent.BaseNotifyingFuture<T>

org.infinispan.commons.util.concurrent.NotifyingFutureImpl<T>

All Implemented Interfaces:

Future<T>, NotifyingFuture<T>, NotifyingNotifiableFuture<T>

Direct Known Subclasses:

CompositeNotifyingFuture

public class NotifyingFutureImpl<T>
extends BaseNotifyingFuture<T>
implements NotifyingNotifiableFuture<T>

Constructs an instance of a NotifyingFuture.

Typical usage:

 Object retval = ... // do some work here
 NotifyingFuture nf = new NotifyingFutureImpl();
 rpcManager.broadcastRpcCommandInFuture(nf, command);
 return nf;
 

Since:

4.0

Author:

Manik Surtani

Constructor Summary

Constructors

Constructor and Description
NotifyingFutureImpl()

Method Summary

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
T	get()
T	get(long timeout, TimeUnit unit)
Future<T>	getFuture()
boolean	isCancelled()
boolean	isDone()
void	notifyDone(T result) Notify the listeners that the operation has finished.
void	notifyException(Throwable exception) Notify the listeners that the operation has finished.
void	setFuture(Future<T> future) Setup the future which is wrapped by implementation of this interface.

Methods inherited from class org.infinispan.commons.util.concurrent.BaseNotifyingFuture

attachListener, fireListeners

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commons.util.concurrent.NotifyingFuture

attachListener

Constructor Detail

NotifyingFutureImpl

public NotifyingFutureImpl()

Method Detail

setFuture

public void setFuture(Future<T> future)

Description copied from interface: NotifyingNotifiableFuture

Setup the future which is wrapped by implementation of this interface. Warning: the implementation must synchronize the call setFuture() and notifyDone() to be executed in this order. Also, all calls delegated to the future must be deferred until the network future is set up.

Specified by:

setFuture in interface NotifyingNotifiableFuture<T>

getFuture

public Future<T> getFuture()
                    throws InterruptedException

Throws:

InterruptedException

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<T>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<T>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<T>

get

public T get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

get

public T get(long timeout,
             TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<T>

Throws:

InterruptedException

ExecutionException

TimeoutException

notifyDone

public void notifyDone(T result)

Description copied from interface: NotifyingNotifiableFuture

Notify the listeners that the operation has finished. Subsequent calls for isDone() will return true and subsequent calls for get() will return the provided result.

Specified by:

notifyDone in interface NotifyingNotifiableFuture<T>

notifyException

public void notifyException(Throwable exception)

Description copied from interface: NotifyingNotifiableFuture

Notify the listeners that the operation has finished. Subsequent calls for isDone() will return true and subsequent calls for get() will throw the provided exception.

Specified by:

notifyException in interface NotifyingNotifiableFuture<T>