private class MapReduceTask.MapReduceTaskFuture<R> extends AbstractInProcessFuture<R>
Modifier and Type | Field and Description |
---|---|
private java.util.concurrent.Callable<R> |
call |
private boolean |
cancelled |
private boolean |
done |
Constructor and Description |
---|
MapReduceTask.MapReduceTaskFuture(java.util.concurrent.Callable<R> call) |
Modifier and Type | Method and Description |
---|---|
boolean |
cancel(boolean mayInterruptIfRunning) |
R |
get() |
boolean |
isCancelled() |
boolean |
isDone() |
get
private final java.util.concurrent.Callable<R> call
private volatile boolean cancelled
private volatile boolean done
public MapReduceTask.MapReduceTaskFuture(java.util.concurrent.Callable<R> call)
public R get() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
java.lang.InterruptedException
java.util.concurrent.ExecutionException
public boolean cancel(boolean mayInterruptIfRunning)
cancel
in interface java.util.concurrent.Future<R>
cancel
in class AbstractInProcessFuture<R>
public boolean isCancelled()
isCancelled
in interface java.util.concurrent.Future<R>
isCancelled
in class AbstractInProcessFuture<R>
public boolean isDone()
isDone
in interface java.util.concurrent.Future<R>
isDone
in class AbstractInProcessFuture<R>