org.infinispan.distexec.mapreduce

Class MapReduceTask.MapReduceTaskFuture<R>

java.lang.Object

org.infinispan.distexec.mapreduce.MapReduceTask.MapReduceTaskFuture<R>

Enclosing class:

MapReduceTask<KIn,VIn,KOut,VOut>

private class MapReduceTask.MapReduceTaskFuture<R>
extends 

Field Summary

Fields

Modifier and Type	Field and Description
private java.util.concurrent.Callable<R>	call
private boolean	cancelled
private boolean	done

Constructor Summary

Constructors

Constructor and Description
MapReduceTask.MapReduceTaskFuture(java.util.concurrent.Callable<R> call)

Method Summary

Methods

Modifier and Type	Method and Description
boolean	cancel(boolean mayInterruptIfRunning)
R	get()
boolean	isCancelled()
boolean	isDone()

Methods inherited from class java.lang.Object

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

Field Detail

call

private final java.util.concurrent.Callable<R> call

cancelled

private volatile boolean cancelled

done

private volatile boolean done

Constructor Detail

MapReduceTask.MapReduceTaskFuture

public MapReduceTask.MapReduceTaskFuture(java.util.concurrent.Callable<R> call)

Method Detail

get

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

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

cancel

public boolean cancel(boolean mayInterruptIfRunning)

isCancelled

public boolean isCancelled()

isDone

public boolean isDone()