Package org.glassfish.hk2.runlevel.internal

Class CurrentTaskFuture.QueueRunner

java.lang.Object

org.glassfish.hk2.runlevel.internal.CurrentTaskFuture.QueueRunner

All Implemented Interfaces:

Runnable

Enclosing class:

CurrentTaskFuture

private static class CurrentTaskFuture.QueueRunner
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private final HashSet<ActiveDescriptor<?>>	alreadyTried
private final AsyncRunLevelContext	asyncContext
private final ServiceLocator	locator
private final int	maxThreads
private final CurrentTaskFuture.UpOneLevel	parent
private final Object	parentLock
private final List<ServiceHandle<?>>	queue
private final Object	queueLock
private ServiceHandle<?>	wouldHaveBlocked

Constructor Summary

Constructors

Modifier	Constructor	Description
private	QueueRunner(ServiceLocator locator, AsyncRunLevelContext asyncContext, Object queueLock, List<ServiceHandle<?>> queue, CurrentTaskFuture.UpOneLevel parent, Object parentLock, int maxThreads)

Method Summary

Modifier and Type	Method	Description
private boolean	isWouldBlockRightNow(HashSet<ActiveDescriptor<?>> cycleChecker, ActiveDescriptor<?> checkMe)	This method does a preliminary check of whether or not the descriptor (or any children) would cause the thread to block.
private void	oneJob(ServiceHandle<?> fService, boolean block)
void	run()

Methods inherited from class java.lang.Object

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

Field Details

locator

private final ServiceLocator locator

asyncContext

private final AsyncRunLevelContext asyncContext

queueLock

private final Object queueLock

queue

private final List<ServiceHandle<?>> queue

parent

private final CurrentTaskFuture.UpOneLevel parent

parentLock

private final Object parentLock

maxThreads

private final int maxThreads

wouldHaveBlocked

private ServiceHandle<?> wouldHaveBlocked

alreadyTried

private final HashSet<ActiveDescriptor<?>> alreadyTried

Constructor Details

QueueRunner

private QueueRunner(ServiceLocator locator,
 AsyncRunLevelContext asyncContext,
 Object queueLock,
 List<ServiceHandle<?>> queue,
 CurrentTaskFuture.UpOneLevel parent,
 Object parentLock,
 int maxThreads)

Method Details

run

public void run()

Specified by:

run in interface Runnable

isWouldBlockRightNow

private boolean isWouldBlockRightNow(HashSet<ActiveDescriptor<?>> cycleChecker,
 ActiveDescriptor<?> checkMe)

This method does a preliminary check of whether or not the descriptor (or any children) would cause the thread to block. If this method returns true then we do not try this service, which can save on going down the getService stack and on the throwing and creation of WouldBlockException

Parameters:

cycleChecker - To ensure we are not caught in a cycle

checkMe - The descriptor to check

Returns:

false if as far as we know this descriptor would NOT block, true if we think if we tried this descriptor right now that it would block

oneJob

private void oneJob(ServiceHandle<?> fService,
 boolean block)