org.globus.cog.karajan.workflow.events
Class WorkerManager

java.lang.Object
  org.globus.cog.karajan.workflow.events.WorkerManager

public final class WorkerManager
extends Object

Nested Class Summary

static class

WorkerManager.WorkerSet

Field Summary

static int

DEFAULT_WORKER_COUNT

Constructor Summary

WorkerManager()

Method Summary

void	addWorker()
int	getDefaultWorkerCount()
edu.emory.mathcs.backport.java.util.Queue	getIdle()
Collection	getWorking()
void	releaseWorker(EventWorker worker)
EventWorker	reserveWorker()
void	setDefaultWorkerCount(int defaultWorkerCount)

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_WORKER_COUNT

public static final int DEFAULT_WORKER_COUNT

Constructor Detail

WorkerManager

public WorkerManager()

Method Detail

reserveWorker

public EventWorker reserveWorker()
                          throws InterruptedException

Throws:

InterruptedException

releaseWorker

public void releaseWorker(EventWorker worker)

addWorker

public void addWorker()

getIdle

public edu.emory.mathcs.backport.java.util.Queue getIdle()

getWorking

public Collection getWorking()

getDefaultWorkerCount

public int getDefaultWorkerCount()

setDefaultWorkerCount

public void setDefaultWorkerCount(int defaultWorkerCount)