Package org.glassfish.hk2.runlevel.internal

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

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()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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 interface java.lang.Runnable

fail

private void fail(java.lang.Throwable th,
                  Descriptor descriptor)

jobComplete

private void jobComplete()