Class DistributedExecutionCompletionService<V>

  • All Implemented Interfaces:

    public class DistributedExecutionCompletionService<V>
    extends Object
    implements CompletionService<V>
    A CompletionService that uses a supplied DistributedExecutorService to execute tasks. This class arranges that submitted tasks are, upon completion, placed on a queue accessible using take. The class is lightweight enough to be suitable for transient use when processing groups of tasks.

    This class must be used instead of a ExecutorCompletionService provided from java.util.concurrent package. The ExecutorCompletionService may not be used since it requires the use of a non serializable RunnableFuture object.

    William Burns, Vladimir Blagojevic