org.infinispan.distexec

Class DefaultExecutorService.DistributedRunnableFuture<V>

java.lang.Object

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

All Implemented Interfaces:

Runnable, Future<V>, RunnableFuture<V>, NotifyingFuture<V>, NotifyingNotifiableFuture<V>

Enclosing class:

DefaultExecutorService

protected static class DefaultExecutorService.DistributedRunnableFuture<V>
extends Object
implements RunnableFuture<V>, NotifyingNotifiableFuture<V>

DistributedRunnableFuture is essentially a Future wrap around DistributedExecuteCommand.

Author:

Mircea Markus, Vladimir Blagojevic

Constructor Summary

Constructors

Constructor and Description
DefaultExecutorService.DistributedRunnableFuture(DistributedExecuteCommand<V> command) Creates a DistributedRunnableFuture that will upon running, execute the given Runnable, and arrange that get will return the given result on successful completion.

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)
boolean	equals(Object o)
V	get()
V	get(long timeout, TimeUnit unit)
DistributedExecuteCommand<V>	getCommand()
int	hashCode()
boolean	isCancelled()
boolean	isDone()
void	notifyDone()
void	run()
void	setNetworkFuture(Future<V> future)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultExecutorService.DistributedRunnableFuture

public DefaultExecutorService.DistributedRunnableFuture(DistributedExecuteCommand<V> command)

Creates a DistributedRunnableFuture that will upon running, execute the given Runnable, and arrange that get will return the given result on successful completion.

Parameters:

runnable - the runnable task

result - the result to return on successful completion.

Method Detail

getCommand

public DistributedExecuteCommand<V> getCommand()

isCancelled

public boolean isCancelled()

Specified by:

isCancelled in interface Future<V>

isDone

public boolean isDone()

Specified by:

isDone in interface Future<V>

cancel

public boolean cancel(boolean mayInterruptIfRunning)

Specified by:

cancel in interface Future<V>

get

public V get()
      throws InterruptedException,
             ExecutionException

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

get

public V get(long timeout,
    TimeUnit unit)
      throws InterruptedException,
             ExecutionException,
             TimeoutException

Specified by:

get in interface Future<V>

Throws:

InterruptedException

ExecutionException

TimeoutException

run

public void run()

Specified by:

run in interface Runnable

Specified by:

run in interface RunnableFuture<V>

notifyDone

public void notifyDone()

Specified by:

notifyDone in interface NotifyingNotifiableFuture<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'.

Specified by:

attachListener in interface NotifyingFuture<V>

Parameters:

listener - listener to attach

Returns:

the same future instance

setNetworkFuture

public void setNetworkFuture(Future<V> future)

Specified by:

setNetworkFuture in interface NotifyingNotifiableFuture<V>

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object