Class CurrentTaskFuture.UpOneLevel
java.lang.Object
org.glassfish.hk2.runlevel.internal.CurrentTaskFuture.UpOneLevel
- All Implemented Interfaces:
Runnable
- Enclosing class:
CurrentTaskFuture
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate MultiException
private boolean
private final long
private int
private final CurrentTaskFuture
private boolean
private CurrentTaskFuture.CancelTimer
private final List
<ServiceHandle<RunLevelListener>> private final Object
private final CurrentTaskFuture.UpAllTheWay
private final int
private int
private int
private final HashSet
<ServiceHandle<?>> private final Object
private final List
<ServiceHandle<Sorter>> private final int
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprivate
UpOneLevel
(int paramUpToThisLevel, CurrentTaskFuture.UpAllTheWay master, CurrentTaskFuture currentTaskFuture, List<ServiceHandle<RunLevelListener>> listeners, List<ServiceHandle<Sorter>> sorters, int maxThreads, long cancelTimeout) -
Method Summary
Modifier and TypeMethodDescriptionprivate List
<ServiceHandle<?>> applySorters
(List<ServiceHandle<?>> jobs) private void
cancel()
private void
fail
(Throwable th, Descriptor descriptor) private int
private void
private void
private void
jobFinished
(ServiceHandle<?> handle) private void
jobRunning
(ServiceHandle<?> handle) void
run()
-
Field Details
-
lock
-
queueLock
-
upToThisLevel
private final int upToThisLevel -
currentTaskFuture
-
listeners
-
sorters
-
master
-
maxThreads
private final int maxThreads -
cancelTimeout
private final long cancelTimeout -
numJobs
private int numJobs -
completedJobs
private int completedJobs -
accumulatedExceptions
-
cancelled
private boolean cancelled -
hardCanceller
-
numJobsRunning
private int numJobsRunning -
hardCancelled
private boolean hardCancelled -
outstandingHandles
-
-
Constructor Details
-
UpOneLevel
private UpOneLevel(int paramUpToThisLevel, CurrentTaskFuture.UpAllTheWay master, CurrentTaskFuture currentTaskFuture, List<ServiceHandle<RunLevelListener>> listeners, List<ServiceHandle<Sorter>> sorters, int maxThreads, long cancelTimeout)
-
-
Method Details