Uses of Interface
org.jgroups.util.NotifyingFuture
-
Packages that use NotifyingFuture Package Description 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.executor
Classes in org.jgroups.blocks.executor that implement NotifyingFuture Modifier and Type Class Description 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 Modifier and Type Field Description protected java.util.concurrent.BlockingQueue<NotifyingFuture<V>>
ExecutionCompletionService. completionQueue
Methods in org.jgroups.blocks.executor that return NotifyingFuture Modifier and Type Method Description NotifyingFuture<V>
ExecutionCompletionService. poll()
{@inheritDoc CompletionService}NotifyingFuture<V>
ExecutionCompletionService. poll(long timeout, java.util.concurrent.TimeUnit unit)
{@inheritDoc CompletionService}NotifyingFuture<V>
ExecutionService.DistributedFuture. setListener(FutureListener<V> listener)
<T> NotifyingFuture<T>
ExecutionService. submit(java.lang.Runnable task, T result)
<T> NotifyingFuture<T>
ExecutionService. submit(java.util.concurrent.Callable<T> task)
NotifyingFuture<V>
ExecutionCompletionService. take()
{@inheritDoc CompletionService}Constructor parameters in org.jgroups.blocks.executor with type arguments of type NotifyingFuture Constructor Description 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
Methods in org.jgroups.util that return NotifyingFuture Modifier and Type Method Description NotifyingFuture<T>
NotifyingFuture. setListener(FutureListener<T> listener)
Attaches a listener and returns the same future instance, to allow for 'building' futures.
-