Package org.glassfish.hk2.runlevel.internal

Class CurrentTaskFuture.UpAllTheWay

java.lang.Object

org.glassfish.hk2.runlevel.internal.CurrentTaskFuture.UpAllTheWay

All Implemented Interfaces:

CurrentTaskFuture.AllTheWay

Enclosing class:

CurrentTaskFuture

private class CurrentTaskFuture.UpAllTheWay
extends Object
implements CurrentTaskFuture.AllTheWay

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	cancelled
private final long	cancelTimeout
private CurrentTaskFuture.UpOneLevel	currentJob
private boolean	done
private MultiException	exception
private final CurrentTaskFuture	future
private int	goingTo
private final List<ServiceHandle<RunLevelListener>>	listeners
private final Object	lock
private final int	maxThreads
private boolean	repurposed
private final List<ServiceHandle<Sorter>>	sorters
private final boolean	useThreads
private int	workingOn

Constructor Summary

Constructors

Modifier	Constructor	Description
private	UpAllTheWay(int goingTo, CurrentTaskFuture future, List<ServiceHandle<RunLevelListener>> listeners, List<ServiceHandle<Sorter>> sorters, int maxThreads, boolean useThreads, long cancelTimeout)

Method Summary

Modifier and Type	Method	Description
private void	cancel()
private void	currentJobComplete(MultiException accumulatedExceptions)
private void	go()
private void	setGoingTo(int goingTo, boolean repurposed)
Boolean	waitForResult(long timeout, TimeUnit unit)	The method to call on the internal job

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

goingTo

private int goingTo

maxThreads

private final int maxThreads

useThreads

private final boolean useThreads

future

private final CurrentTaskFuture future

listeners

private final List<ServiceHandle<RunLevelListener>> listeners

sorters

private final List<ServiceHandle<Sorter>> sorters

cancelTimeout

private final long cancelTimeout

workingOn

private int workingOn

currentJob

private CurrentTaskFuture.UpOneLevel currentJob

cancelled

private boolean cancelled

done

private boolean done

repurposed

private boolean repurposed

exception

private MultiException exception

Constructor Details

UpAllTheWay

private UpAllTheWay(int goingTo,
 CurrentTaskFuture future,
 List<ServiceHandle<RunLevelListener>> listeners,
 List<ServiceHandle<Sorter>> sorters,
 int maxThreads,
 boolean useThreads,
 long cancelTimeout)

Method Details

cancel

private void cancel()

waitForResult

public Boolean waitForResult(long timeout,
 TimeUnit unit)
                      throws InterruptedException,
MultiException

Description copied from interface: CurrentTaskFuture.AllTheWay

The method to call on the internal job

Specified by:

waitForResult in interface CurrentTaskFuture.AllTheWay

Parameters:

timeout - The amount of time to wait for a result

unit - The unit of the above time value

Returns:

True if the job finished, False if the timeout is up prior to the job finishing, and null if the job was repurposed and the caller may now need to listen on a different job

Throws:

InterruptedException - On a thread getting jacked

MultiException - Other exceptions

setGoingTo

private void setGoingTo(int goingTo,
 boolean repurposed)

go

private void go()

currentJobComplete

private void currentJobComplete(MultiException accumulatedExceptions)