org.infinispan.distexec

Class DefaultExecutorService.LocalDistributedTaskPart<V>

java.lang.Object

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

org.infinispan.distexec.DefaultExecutorService.LocalDistributedTaskPart<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.LocalDistributedTaskPart<V>
extends DefaultExecutorService.DistributedTaskPart<V>

Field Summary

Fields

Modifier and Type	Field and Description
private NotifyingFutureImpl<V>	future

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

distCommand

Constructor Summary

Constructors

Constructor and Description
DefaultExecutorService.LocalDistributedTaskPart(DistributedTask<V> task, org.infinispan.commands.read.DistributedExecuteCommand<V> command, java.util.List<java.lang.Object> inputKeys, 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()

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

future

private final NotifyingFutureImpl<V> future

Constructor Detail

DefaultExecutorService.LocalDistributedTaskPart

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

Method Detail

isDone

public boolean isDone()

cancel

public boolean cancel(boolean mayInterruptIfRunning)

getResult

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

Specified by:

getResult in class DefaultExecutorService.DistributedTaskPart<V>

Throws:

java.lang.Exception

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>

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