Uses of Interface
org.jgroups.util.NotifyingFuture

Packages that use NotifyingFuture

org.jgroups.blocks	Provides building blocks that are layered on top of channels.
org.jgroups.blocks.executor
org.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

Uses of NotifyingFuture in org.jgroups.blocks

Classes in org.jgroups.blocks that implement NotifyingFuture

class	GroupRequest<T> Sends a message to all members of the group and waits for all responses (or timeout).
class	Request Abstract class for a unicast or multicast request
class	UnicastRequest<T> Sends a request to a single target destination

Methods in org.jgroups.blocks that return NotifyingFuture

<T> NotifyingFuture<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options) Invokes a method in all members and expects responses from members contained in dests (or all members if dests is null).
<T> NotifyingFuture<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options) Invokes a method in a cluster member and - if blocking - returns the result
<T> NotifyingFuture<RspList<T>>	MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options) Sends a message to all members and expects responses from members in dests (if non-null).
<T> NotifyingFuture<T>	MessageDispatcher.sendMessageWithFuture(Message msg, RequestOptions options) Sends a unicast message to the target defined by msg.getDest() and returns a future
NotifyingFuture	Request.setListener(FutureListener listener)

Uses of NotifyingFuture in org.jgroups.blocks.executor

Classes in org.jgroups.blocks.executor that implement NotifyingFuture

static class

ExecutionService.DistributedFuture<V> This is basically a copy of the FutureTask in java.util.concurrent but added serializable to it.

Fields in org.jgroups.blocks.executor with type parameters of type NotifyingFuture

protected java.util.concurrent.BlockingQueue<NotifyingFuture<V>>

ExecutionCompletionService.completionQueue

Methods in org.jgroups.blocks.executor that return NotifyingFuture

NotifyingFuture<V>	ExecutionCompletionService.poll()
NotifyingFuture<V>	ExecutionCompletionService.poll(long timeout, java.util.concurrent.TimeUnit unit)
NotifyingFuture<V>	ExecutionService.DistributedFuture.setListener(FutureListener<V> listener)
<T> NotifyingFuture<T>	ExecutionService.submit(java.util.concurrent.Callable<T> task)
<T> NotifyingFuture<T>	ExecutionService.submit(java.lang.Runnable task, T result)
NotifyingFuture<V>	ExecutionCompletionService.take()

Constructor parameters in org.jgroups.blocks.executor with type arguments of type NotifyingFuture

ExecutionCompletionService(ExecutionService executor, java.util.concurrent.BlockingQueue<NotifyingFuture<V>> completionQueue)
Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.

ExecutionCompletionService(ExecutionService executor, java.util.concurrent.BlockingQueue<NotifyingFuture<V>> completionQueue, ExecutionCompletionService.QueueingListener listener)
This constructor is here if someone wants to override this class and provide their own QueueingListener to possibly listen in on futures being finished

Uses of NotifyingFuture in org.jgroups.util

Classes in org.jgroups.util that implement NotifyingFuture

class

NullFuture<T>

Methods in org.jgroups.util that return NotifyingFuture

NotifyingFuture	NotifyingFuture.setListener(FutureListener<T> listener) Attaches a listener and returns the same future instance, to allow for 'building' futures.
NotifyingFuture	NullFuture.setListener(FutureListener<T> listener)