private class CurrentTaskFuture.UpOneLevel
extends java.lang.Object
implements java.lang.Runnable
Modifier and Type | Field and Description |
---|---|
private MultiException |
accumulatedExceptions |
private boolean |
cancelled |
private long |
cancelTimeout |
private int |
completedJobs |
private CurrentTaskFuture |
currentTaskFuture |
private boolean |
hardCancelled |
private CurrentTaskFuture.CancelTimer |
hardCanceller |
private java.util.List<ServiceHandle<RunLevelListener>> |
listeners |
private java.lang.Object |
lock |
private CurrentTaskFuture.UpAllTheWay |
master |
private int |
maxThreads |
private int |
numJobs |
private int |
numJobsRunning |
private java.util.HashSet<ServiceHandle<?>> |
outstandingHandles |
private java.lang.Object |
queueLock |
private java.util.List<ServiceHandle<Sorter>> |
sorters |
private int |
upToThisLevel |
Modifier | Constructor and Description |
---|---|
private |
UpOneLevel(int paramUpToThisLevel,
CurrentTaskFuture.UpAllTheWay master,
CurrentTaskFuture currentTaskFuture,
java.util.List<ServiceHandle<RunLevelListener>> listeners,
java.util.List<ServiceHandle<Sorter>> sorters,
int maxThreads,
long cancelTimeout) |
Modifier and Type | Method and Description |
---|---|
private java.util.List<ServiceHandle<?>> |
applySorters(java.util.List<ServiceHandle<?>> jobs) |
private void |
cancel() |
private void |
fail(java.lang.Throwable th,
Descriptor descriptor) |
private int |
getJobsRunning() |
private void |
hardCancel() |
private void |
jobComplete() |
private void |
jobFinished(ServiceHandle<?> handle) |
private void |
jobRunning(ServiceHandle<?> handle) |
void |
run() |
private final java.lang.Object lock
private final java.lang.Object queueLock
private final int upToThisLevel
private final CurrentTaskFuture currentTaskFuture
private final java.util.List<ServiceHandle<RunLevelListener>> listeners
private final java.util.List<ServiceHandle<Sorter>> sorters
private final CurrentTaskFuture.UpAllTheWay master
private final int maxThreads
private final long cancelTimeout
private int numJobs
private int completedJobs
private MultiException accumulatedExceptions
private boolean cancelled
private CurrentTaskFuture.CancelTimer hardCanceller
private int numJobsRunning
private boolean hardCancelled
private final java.util.HashSet<ServiceHandle<?>> outstandingHandles
private UpOneLevel(int paramUpToThisLevel, CurrentTaskFuture.UpAllTheWay master, CurrentTaskFuture currentTaskFuture, java.util.List<ServiceHandle<RunLevelListener>> listeners, java.util.List<ServiceHandle<Sorter>> sorters, int maxThreads, long cancelTimeout)
private void cancel()
private void hardCancel()
private void jobRunning(ServiceHandle<?> handle)
private void jobFinished(ServiceHandle<?> handle)
private int getJobsRunning()
private java.util.List<ServiceHandle<?>> applySorters(java.util.List<ServiceHandle<?>> jobs)
public void run()
run
in interface java.lang.Runnable
private void fail(java.lang.Throwable th, Descriptor descriptor)
private void jobComplete()