Package org.glassfish.hk2.runlevel.internal

Class CurrentTaskFuture.UpOneLevel

java.lang.Object

org.glassfish.hk2.runlevel.internal.CurrentTaskFuture.UpOneLevel

All Implemented Interfaces:

Runnable

Enclosing class:

CurrentTaskFuture

private class CurrentTaskFuture.UpOneLevel
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private MultiException	accumulatedExceptions
private boolean	cancelled
private final long	cancelTimeout
private int	completedJobs
private final CurrentTaskFuture	currentTaskFuture
private boolean	hardCancelled
private CurrentTaskFuture.CancelTimer	hardCanceller
private final List<ServiceHandle<RunLevelListener>>	listeners
private final Object	lock
private final CurrentTaskFuture.UpAllTheWay	master
private final int	maxThreads
private int	numJobs
private int	numJobsRunning
private final HashSet<ServiceHandle<?>>	outstandingHandles
private final Object	queueLock
private final List<ServiceHandle<Sorter>>	sorters
private final int	upToThisLevel

Constructor Summary

Constructors

Modifier	Constructor	Description
private	UpOneLevel(int paramUpToThisLevel, CurrentTaskFuture.UpAllTheWay master, CurrentTaskFuture currentTaskFuture, List<ServiceHandle<RunLevelListener>> listeners, List<ServiceHandle<Sorter>> sorters, int maxThreads, long cancelTimeout)

Method Summary

Modifier and Type	Method	Description
private List<ServiceHandle<?>>	applySorters(List<ServiceHandle<?>> jobs)
private void	cancel()
private void	fail(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 Details

lock

private final Object lock

queueLock

private final Object queueLock

upToThisLevel

private final int upToThisLevel

currentTaskFuture

private final CurrentTaskFuture currentTaskFuture

listeners

private final List<ServiceHandle<RunLevelListener>> listeners

sorters

private final 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 HashSet<ServiceHandle<?>> 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

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 List<ServiceHandle<?>> applySorters(List<ServiceHandle<?>> jobs)

run

public void run()

Specified by:

run in interface Runnable

fail

private void fail(Throwable th,
 Descriptor descriptor)

jobComplete

private void jobComplete()