Package | Description |
---|---|
org.infinispan.distexec |
Distribute Executor APIs
|
Modifier and Type | Method and Description |
---|---|
DistributedTask<T> |
DistributedTaskBuilder.build()
Completes creation of DistributedTask with the currently provided attributes of this
DistributedTaskBuilder
|
Modifier and Type | Method and Description |
---|---|
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T> |
DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task,
DistributedExecuteCommand<T> c,
Address target,
int failoverCount) |
protected <T,K> org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<T> |
DefaultExecutorService.createDistributedTaskPart(DistributedTask<T> task,
DistributedExecuteCommand<T> c,
List<K> inputKeys,
Address target,
int failoverCount) |
protected <T> List |
DefaultExecutorService.executionCandidates(DistributedTask<T> task) |
protected <T> Address |
DefaultExecutorService.selectExecutionNode(DistributedTask<T> task) |
<T> NotifyingFuture<T> |
DefaultExecutorService.submit(Address target,
DistributedTask<T> task) |
<T> NotifyingFuture<T> |
DistributedExecutorService.submit(Address target,
DistributedTask<T> task)
Submits the given DistributedTask for execution on the specified target Infinispan node.
|
<T,K> NotifyingFuture<T> |
DefaultExecutorService.submit(DistributedTask<T> task,
K... input) |
<T,K> NotifyingFuture<T> |
DistributedExecutorService.submit(DistributedTask<T> task,
K... input)
Submits the given DistributedTask for execution on a single Infinispan node.
|
<T> List<Future<T>> |
DefaultExecutorService.submitEverywhere(DistributedTask<T> task) |
<T> List<Future<T>> |
DistributedExecutorService.submitEverywhere(DistributedTask<T> task)
Submits the given DistributedTask for execution on all available Infinispan nodes.
|
<T,K> List<Future<T>> |
DefaultExecutorService.submitEverywhere(DistributedTask<T> task,
K... input) |
<T,K> List<Future<T>> |
DistributedExecutorService.submitEverywhere(DistributedTask<T> task,
K... input)
Submits the given DistributedTask for execution on all available Infinispan nodes using input
keys specified by K input.
|
Copyright © 2015 JBoss, a division of Red Hat. All rights reserved.