org.infinispan.distexec

Class DefaultExecutorService.DistributedTaskPart<V>

java.lang.Object

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

All Implemented Interfaces:

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

Direct Known Subclasses:

DefaultExecutorService.LocalDistributedTaskPart, DefaultExecutorService.RemoteDistributedTaskPart

Enclosing class:

DefaultExecutorService

private abstract class DefaultExecutorService.DistributedTaskPart<V>
extends java.lang.Object
implements NotifyingFuture<V>, java.util.concurrent.RunnableFuture<V>

DistributedTaskPart represents a unit of work sent to remote VM and executed there

Author:

Mircea Markus, Vladimir Blagojevic

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	cancelled
protected org.infinispan.commands.read.DistributedExecuteCommand<V>	distCommand
private int	failedOverCount
private java.util.List<java.lang.Object>	inputKeys
private DistributedTask<V>	owningTask

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	DefaultExecutorService.DistributedTaskPart(java.util.List<java.lang.Object> inputKeys, org.infinispan.commands.read.DistributedExecuteCommand<V> command, DistributedTask<V> task, int failedOverCount)

Method Summary

Methods

Modifier and Type	Method and Description
protected long	computeTimeoutNanos(long timeout, java.util.concurrent.TimeUnit unit)
boolean	equals(java.lang.Object obj)
abstract void	execute()
protected V	failoverExecution(java.lang.Exception cause, long timeout, java.util.concurrent.TimeUnit unit)
V	get()
V	get(long timeout, java.util.concurrent.TimeUnit unit)
org.infinispan.commands.read.DistributedExecuteCommand<V>	getCommand()
abstract org.infinispan.remoting.transport.Address	getExecutionTarget()
java.util.List<java.lang.Object>	getInputKeys()
private DefaultExecutorService	getOuterType()
DistributedTask<V>	getOwningTask()
protected abstract V	getResult(long timeoutNanos)
int	hashCode()
protected V	innerGet(long timeout, java.util.concurrent.TimeUnit unit)
boolean	isCancelled()
void	run()
protected void	setCancelled()
protected java.util.concurrent.ExecutionException	wrapIntoExecutionException(java.lang.Exception e)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.infinispan.commons.util.concurrent.NotifyingFuture

attachListener

Methods inherited from interface java.util.concurrent.Future

cancel, isDone

Field Detail

distCommand

protected final org.infinispan.commands.read.DistributedExecuteCommand<V> distCommand

inputKeys

private final java.util.List<java.lang.Object> inputKeys

owningTask

private final DistributedTask<V> owningTask

failedOverCount

private int failedOverCount

cancelled

private volatile boolean cancelled

Constructor Detail

DefaultExecutorService.DistributedTaskPart

protected DefaultExecutorService.DistributedTaskPart(java.util.List<java.lang.Object> inputKeys,
                                          org.infinispan.commands.read.DistributedExecuteCommand<V> command,
                                          DistributedTask<V> task,
                                          int failedOverCount)

Method Detail

getInputKeys

public java.util.List<java.lang.Object> getInputKeys()

getCommand

public org.infinispan.commands.read.DistributedExecuteCommand<V> getCommand()

getOwningTask

public DistributedTask<V> getOwningTask()

getExecutionTarget

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

getOuterType

private DefaultExecutorService getOuterType()

execute

public abstract void execute()

run

public void run()

Specified by:

run in interface java.lang.Runnable

Specified by:

run in interface java.util.concurrent.RunnableFuture<V>

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface java.util.concurrent.Future<V>

get

public V get()
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

get

public V get(long timeout,
    java.util.concurrent.TimeUnit unit)
      throws java.lang.InterruptedException,
             java.util.concurrent.ExecutionException,
             java.util.concurrent.TimeoutException

Specified by:

get in interface java.util.concurrent.Future<V>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

innerGet

protected V innerGet(long timeout,
         java.util.concurrent.TimeUnit unit)
              throws java.util.concurrent.ExecutionException,
                     java.util.concurrent.TimeoutException,
                     java.lang.InterruptedException

Throws:

java.util.concurrent.ExecutionException

java.util.concurrent.TimeoutException

java.lang.InterruptedException

getResult

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

Throws:

java.lang.Exception

computeTimeoutNanos

protected long computeTimeoutNanos(long timeout,
                       java.util.concurrent.TimeUnit unit)

wrapIntoExecutionException

protected java.util.concurrent.ExecutionException wrapIntoExecutionException(java.lang.Exception e)

failoverExecution

protected V failoverExecution(java.lang.Exception cause,
                  long timeout,
                  java.util.concurrent.TimeUnit unit)
                       throws java.lang.Exception

Throws:

java.lang.Exception

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

setCancelled

protected void setCancelled()