private class CurrentTaskFuture.UpAllTheWay extends java.lang.Object implements CurrentTaskFuture.AllTheWay
Modifier and Type | Field and Description |
---|---|
private boolean |
cancelled |
private long |
cancelTimeout |
private CurrentTaskFuture.UpOneLevel |
currentJob |
private boolean |
done |
private MultiException |
exception |
private CurrentTaskFuture |
future |
private int |
goingTo |
private java.util.List<ServiceHandle<RunLevelListener>> |
listeners |
private java.lang.Object |
lock |
private int |
maxThreads |
private boolean |
repurposed |
private java.util.List<ServiceHandle<Sorter>> |
sorters |
private boolean |
useThreads |
private int |
workingOn |
Modifier | Constructor and Description |
---|---|
private |
UpAllTheWay(int goingTo,
CurrentTaskFuture future,
java.util.List<ServiceHandle<RunLevelListener>> listeners,
java.util.List<ServiceHandle<Sorter>> sorters,
int maxThreads,
boolean useThreads,
long cancelTimeout) |
Modifier and Type | Method and Description |
---|---|
private void |
cancel() |
private void |
currentJobComplete(MultiException accumulatedExceptions) |
private void |
go() |
private void |
setGoingTo(int goingTo,
boolean repurposed) |
java.lang.Boolean |
waitForResult(long timeout,
java.util.concurrent.TimeUnit unit)
The method to call on the internal job
|
private final java.lang.Object lock
private int goingTo
private final int maxThreads
private final boolean useThreads
private final CurrentTaskFuture future
private final java.util.List<ServiceHandle<RunLevelListener>> listeners
private final java.util.List<ServiceHandle<Sorter>> sorters
private final long cancelTimeout
private int workingOn
private CurrentTaskFuture.UpOneLevel currentJob
private boolean cancelled
private boolean done
private boolean repurposed
private MultiException exception
private UpAllTheWay(int goingTo, CurrentTaskFuture future, java.util.List<ServiceHandle<RunLevelListener>> listeners, java.util.List<ServiceHandle<Sorter>> sorters, int maxThreads, boolean useThreads, long cancelTimeout)
private void cancel()
public java.lang.Boolean waitForResult(long timeout, java.util.concurrent.TimeUnit unit) throws java.lang.InterruptedException, MultiException
CurrentTaskFuture.AllTheWay
waitForResult
in interface CurrentTaskFuture.AllTheWay
timeout
- The amount of time to wait for a resultunit
- The unit of the above time valuejava.lang.InterruptedException
- On a thread getting jackedMultiException
- Other exceptionsprivate void setGoingTo(int goingTo, boolean repurposed)
private void go()
private void currentJobComplete(MultiException accumulatedExceptions)