org.infinispan.distexec

Class DefaultExecutorService.RemoteDistributedTaskPart<V>

java.lang.Object

org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart<V>

org.infinispan.distexec.DefaultExecutorService.RemoteDistributedTaskPart<V>

All Implemented Interfaces:

java.lang.Runnable, java.util.concurrent.Future<V>, java.util.concurrent.RunnableFuture<V>, NotifyingFuture<V>

Enclosing class:

DefaultExecutorService

private class DefaultExecutorService.RemoteDistributedTaskPart<V>
extends DefaultExecutorService.DistributedTaskPart<V>

Field Summary

Fields

Modifier and Type	Field and Description
private org.infinispan.remoting.transport.Address	executionTarget
private NotifyingFutureImpl<java.lang.Object>	future

Fields inherited from class org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart

distCommand

Constructor Summary

Constructors

Constructor and Description
DefaultExecutorService.RemoteDistributedTaskPart(DistributedTask<V> task, org.infinispan.commands.read.DistributedExecuteCommand<V> command, java.util.List<java.lang.Object> inputKeys, org.infinispan.remoting.transport.Address executionTarget, int failoverCount)

Method Summary

Methods

Modifier and Type	Method and Description
NotifyingFuture<V>	attachListener(FutureListener<V> listener) Attaches a listener and returns the same future instance, to allow for 'building'.
boolean	cancel(boolean mayInterruptIfRunning)
void	execute()
org.infinispan.remoting.transport.Address	getExecutionTarget()
protected V	getResult(long timeoutNanos)
boolean	isDone()
private V	retrieveResult(java.lang.Object response)

Methods inherited from class org.infinispan.distexec.DefaultExecutorService.DistributedTaskPart

computeTimeoutNanos, equals, failoverExecution, get, get, getCommand, getInputKeys, getOwningTask, hashCode, innerGet, isCancelled, run, setCancelled, wrapIntoExecutionException

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

executionTarget

private final org.infinispan.remoting.transport.Address executionTarget

future

private final NotifyingFutureImpl<java.lang.Object> future

Constructor Detail

DefaultExecutorService.RemoteDistributedTaskPart

public DefaultExecutorService.RemoteDistributedTaskPart(DistributedTask<V> task,
                                                org.infinispan.commands.read.DistributedExecuteCommand<V> command,
                                                java.util.List<java.lang.Object> inputKeys,
                                                org.infinispan.remoting.transport.Address executionTarget,
                                                int failoverCount)

Method Detail

getExecutionTarget

public org.infinispan.remoting.transport.Address getExecutionTarget()

Specified by:

getExecutionTarget in class DefaultExecutorService.DistributedTaskPart<V>

execute

public void execute()

Specified by:

execute in class DefaultExecutorService.DistributedTaskPart<V>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

isDone

public boolean isDone()

getResult

protected V getResult(long timeoutNanos)
               throws java.lang.Exception

Specified by:

getResult in class DefaultExecutorService.DistributedTaskPart<V>

Throws:

java.lang.Exception

retrieveResult

private V retrieveResult(java.lang.Object response)
                  throws java.lang.Exception

Throws:

java.lang.Exception

attachListener

public NotifyingFuture<V> attachListener(FutureListener<V> listener)

Description copied from interface: NotifyingFuture

Attaches a listener and returns the same future instance, to allow for 'building'.

Parameters:

listener - listener to attach

Returns:

the same future instance