Uses of Interface
org.jgroups.util.NotifyingFuture
Packages that use NotifyingFuture
Package
Description
Provides building blocks that are layered on top of channels.
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 NotifyingFutureModifier and TypeClassDescriptionclassSends a message to all members of the group and waits for all responses (or timeout).classSends a request to multiple destinations.classAbstract class for a unicast or multicast requestclassSends a request to a single target destinationMethods in org.jgroups.blocks that return NotifyingFutureModifier and TypeMethodDescriptionRpcDispatcher.callRemoteMethodsWithFuture(Collection<Address> dests, MethodCall method_call, RequestOptions options) RpcDispatcher.callRemoteMethodsWithFuture(Vector<Address> dests, MethodCall method_call) Deprecated.RpcDispatcher.callRemoteMethodsWithFuture(Vector<Address> dests, MethodCall method_call, int mode, long timeout, boolean use_anycasting, boolean oob, RspFilter filter) Deprecated.<T> NotifyingFuture<T> RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call) Deprecated.<T> NotifyingFuture<T> RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall method_call, int mode, long timeout, boolean oob) Deprecated.<T> NotifyingFuture<T> RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options) MessageDispatcher.castMessageWithFuture(Collection<Address> dests, Message msg, RequestOptions options) MessageDispatcher.castMessageWithFuture(Vector dests, Message msg, int mode, long timeout, boolean use_anycasting, RspFilter filter) Deprecated.<T> NotifyingFuture<T> MessageDispatcher.sendMessageWithFuture(Message msg, int mode, long timeout) Deprecated.<T> NotifyingFuture<T> MessageDispatcher.sendMessageWithFuture(Message msg, RequestOptions options) Request.setListener(FutureListener listener) -
Uses of NotifyingFuture in org.jgroups.blocks.executor
Classes in org.jgroups.blocks.executor that implement NotifyingFutureModifier and TypeClassDescriptionstatic classThis 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 NotifyingFutureModifier and TypeFieldDescriptionprotected final BlockingQueue<NotifyingFuture<V>> ExecutionCompletionService.completionQueueMethods in org.jgroups.blocks.executor that return NotifyingFutureModifier and TypeMethodDescriptionExecutionCompletionService.poll()invalid @inheritDoc
{@inheritDoc CompletionService}invalid @inheritDoc
{@inheritDoc CompletionService}ExecutionService.DistributedFuture.setListener(FutureListener<V> listener) <T> NotifyingFuture<T> <T> NotifyingFuture<T> ExecutionCompletionService.take()invalid @inheritDoc
{@inheritDoc CompletionService}Constructor parameters in org.jgroups.blocks.executor with type arguments of type NotifyingFutureModifierConstructorDescriptionExecutionCompletionService(ExecutionService executor, BlockingQueue<NotifyingFuture<V>> completionQueue) Creates an ExecutorCompletionService using the supplied executor for base task execution and the supplied queue as its completion queue.protectedExecutionCompletionService(ExecutionService executor, BlockingQueue<NotifyingFuture<V>> completionQueue, ExecutionCompletionService<V>.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 NotifyingFutureMethods in org.jgroups.util that return NotifyingFutureModifier and TypeMethodDescriptionNotifyingFuture.setListener(FutureListener<T> listener) Attaches a listener and returns the same future instance, to allow for 'building' futures.NullFuture.setListener(FutureListener<T> listener)