Class CurrentTaskFuture.UpOneLevel
- java.lang.Object
-
- org.glassfish.hk2.runlevel.internal.CurrentTaskFuture.UpOneLevel
-
- All Implemented Interfaces:
java.lang.Runnable
- Enclosing class:
- CurrentTaskFuture
private class CurrentTaskFuture.UpOneLevel extends java.lang.Object implements java.lang.Runnable
-
-
Field Summary
Fields Modifier and Type Field 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
-
Constructor Summary
Constructors Modifier Constructor 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)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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()
-
-
-
Field Detail
-
lock
private final java.lang.Object lock
-
queueLock
private final java.lang.Object queueLock
-
upToThisLevel
private final int upToThisLevel
-
currentTaskFuture
private final CurrentTaskFuture currentTaskFuture
-
listeners
private final java.util.List<ServiceHandle<RunLevelListener>> listeners
-
sorters
private final java.util.List<ServiceHandle<Sorter>> sorters
-
master
private final CurrentTaskFuture.UpAllTheWay master
-
maxThreads
private final int maxThreads
-
cancelTimeout
private final long cancelTimeout
-
numJobs
private int numJobs
-
completedJobs
private int completedJobs
-
accumulatedExceptions
private MultiException accumulatedExceptions
-
cancelled
private boolean cancelled
-
hardCanceller
private CurrentTaskFuture.CancelTimer hardCanceller
-
numJobsRunning
private int numJobsRunning
-
hardCancelled
private boolean hardCancelled
-
outstandingHandles
private final java.util.HashSet<ServiceHandle<?>> outstandingHandles
-
-
Constructor Detail
-
UpOneLevel
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)
-
-
Method Detail
-
cancel
private void cancel()
-
hardCancel
private void hardCancel()
-
jobRunning
private void jobRunning(ServiceHandle<?> handle)
-
jobFinished
private void jobFinished(ServiceHandle<?> handle)
-
getJobsRunning
private int getJobsRunning()
-
applySorters
private java.util.List<ServiceHandle<?>> applySorters(java.util.List<ServiceHandle<?>> jobs)
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
-
fail
private void fail(java.lang.Throwable th, Descriptor descriptor)
-
jobComplete
private void jobComplete()
-
-