Package | Description |
---|---|
org.jgroups.blocks.executor | |
org.jgroups.util |
Provides useful functionality which cannot be assigned to any particular other package.
|
Modifier and Type | Class and Description |
---|---|
static class |
ExecutionService.DistributedFuture<V>
This is basically a copy of the FutureTask in java.util.concurrent but
added serializable to it.
|
Modifier and Type | Field and Description |
---|---|
protected BlockingQueue<NotifyingFuture<V>> |
ExecutionCompletionService.completionQueue |
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<V> |
ExecutionCompletionService.poll() |
NotifyingFuture<V> |
ExecutionCompletionService.poll(long timeout,
TimeUnit unit) |
NotifyingFuture<V> |
ExecutionService.DistributedFuture.setListener(FutureListener<V> listener) |
<T> NotifyingFuture<T> |
ExecutionService.submit(Callable<T> task) |
<T> NotifyingFuture<T> |
ExecutionService.submit(Runnable task,
T result) |
NotifyingFuture<V> |
ExecutionCompletionService.take() |
Constructor and Description |
---|
ExecutionCompletionService(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.
|
ExecutionCompletionService(ExecutionService executor,
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
|
Modifier and Type | Method and Description |
---|---|
NotifyingFuture<T> |
NotifyingFuture.setListener(FutureListener<T> listener)
Attaches a listener and returns the same future instance, to allow for 'building' futures.
|
Copyright © 2018 JBoss, a division of Red Hat. All rights reserved.