org.globus.cog.karajan.scheduler.submitQueue
Class AbstractSubmitQueue

java.lang.Object
  org.globus.cog.karajan.scheduler.submitQueue.AbstractSubmitQueue

All Implemented Interfaces:

SubmitQueue

Direct Known Subclasses:

FixedRateQueue, GlobalSubmitQueue, HostSubmitQueue, InstanceSubmitQueue, RateLimiterQueue

public class AbstractSubmitQueue
extends Object
implements SubmitQueue

Constructor Summary

AbstractSubmitQueue(int throttle)

Method Summary

int	getThrottle()
protected boolean	isQueueEmpty()
protected NonBlockingSubmit	poll()
void	queue(NonBlockingSubmit nbs)
void	setThrottle(int throttle)
protected void	step()
void	submitCompleted(NonBlockingSubmit old, Exception ex)

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractSubmitQueue

public AbstractSubmitQueue(int throttle)

Method Detail

queue

public void queue(NonBlockingSubmit nbs)

Specified by:

queue in interface SubmitQueue

submitCompleted

public void submitCompleted(NonBlockingSubmit old,
                            Exception ex)

Specified by:

submitCompleted in interface SubmitQueue

step

protected void step()

poll

protected final NonBlockingSubmit poll()

isQueueEmpty

protected final boolean isQueueEmpty()

getThrottle

public int getThrottle()

setThrottle

public void setThrottle(int throttle)