接口 com.fr.third.jgroups.util.NotifyingFuture
的使用

使用NotifyingFuture的程序包

程序包	说明
com.fr.third.jgroups.blocks	Provides building blocks that are layered on top of channels.
com.fr.third.jgroups.blocks.executor
com.fr.third.jgroups.util	Provides useful functionality which cannot be assigned to any particular other package.

com.fr.third.jgroups.blocks中NotifyingFuture的使用

实现NotifyingFuture的com.fr.third.jgroups.blocks中的类

限定符和类型	类和说明
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

返回NotifyingFuture的com.fr.third.jgroups.blocks中的方法

限定符和类型	方法和说明
<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<RspList<T>>	RpcDispatcher.callRemoteMethodsWithFuture(java.util.Collection<Address> dests, MethodCall method_call, RequestOptions options, FutureListener<RspList<T>> listener) 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<T>	RpcDispatcher.callRemoteMethodWithFuture(Address dest, MethodCall call, RequestOptions options, FutureListener<T> listener) 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<RspList<T>>	MessageDispatcher.castMessageWithFuture(java.util.Collection<Address> dests, Message msg, RequestOptions options, FutureListener<RspList<T>> listener) 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
<T> NotifyingFuture<T>	MessageDispatcher.sendMessageWithFuture(Message msg, RequestOptions options, FutureListener<T> listener) Sends a unicast message to the target defined by msg.getDest() and returns a future
NotifyingFuture	Request.setListener(FutureListener listener)

com.fr.third.jgroups.blocks.executor中NotifyingFuture的使用

实现NotifyingFuture的com.fr.third.jgroups.blocks.executor中的类

限定符和类型	类和说明
static class	ExecutionService.DistributedFuture<V> This is basically a copy of the FutureTask in java.util.concurrent but added serializable to it.

类型参数类型为NotifyingFuture的com.fr.third.jgroups.blocks.executor中的字段

限定符和类型	字段和说明
protected java.util.concurrent.BlockingQueue<NotifyingFuture<V>>	ExecutionCompletionService.completionQueue

返回NotifyingFuture的com.fr.third.jgroups.blocks.executor中的方法

限定符和类型	方法和说明
NotifyingFuture<V>	ExecutionCompletionService.poll() This future may safely be used as a NotifyingFuture if desired.
NotifyingFuture<V>	ExecutionCompletionService.poll(long timeout, java.util.concurrent.TimeUnit unit) This future may safely be used as a NotifyingFuture if desired.
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() This future may safely be used as a NotifyingFuture if desired.

类型变量类型为NotifyingFuture的com.fr.third.jgroups.blocks.executor中的构造器参数

构造器和说明
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

com.fr.third.jgroups.util中NotifyingFuture的使用

实现NotifyingFuture的com.fr.third.jgroups.util中的类

限定符和类型	类和说明
class	NullFuture<T>

返回NotifyingFuture的com.fr.third.jgroups.util中的方法

限定符和类型	方法和说明
NotifyingFuture	NullFuture.setListener(FutureListener<T> listener)
NotifyingFuture	NotifyingFuture.setListener(FutureListener<T> listener) Attaches a listener and returns the same future instance, to allow for 'building' futures.