org.globus.exec.service.exec.utils
Class JobStateMonitorSubscriptionManager

java.lang.Object
  java.lang.Thread
      org.globus.exec.service.exec.utils.JobStateMonitorSubscriptionManager

All Implemented Interfaces:

Runnable

public class JobStateMonitorSubscriptionManager

extends Thread

Nested Class Summary

(package private) class

JobStateMonitorSubscriptionManager.SubscriptionEvent

Field Summary

private static int	DEFAULT_SUBSCRIPTION_MANAGER_THREAD_COUNT
(package private) boolean	done
(package private) static org.globus.util.I18n	i18n
private static JobStateMonitorSubscriptionManager[]	INSTANCES
private static org.apache.commons.logging.Log	logger Log4J logger
(package private) LinkedList	readyQueue
static int	SUBSCRIBE_REQUEST
private static int	subscriptionManagerIndex
static int	UNSUBSCRIBE_REQUEST

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

private

JobStateMonitorSubscriptionManager()

Method Summary

void	add(ManagedExecutableJobResource resource, int action)
static JobStateMonitorSubscriptionManager	getInstance()
void	run()
private void	subscribe(ManagedExecutableJobResource resource)
void	terminate()
private void	unsubscribe(ManagedExecutableJobResource resource)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static org.apache.commons.logging.Log logger

Log4J logger

i18n

static org.globus.util.I18n i18n

readyQueue

LinkedList readyQueue

done

boolean done

DEFAULT_SUBSCRIPTION_MANAGER_THREAD_COUNT

private static int DEFAULT_SUBSCRIPTION_MANAGER_THREAD_COUNT

subscriptionManagerIndex

private static int subscriptionManagerIndex

INSTANCES

private static JobStateMonitorSubscriptionManager[] INSTANCES

SUBSCRIBE_REQUEST

public static int SUBSCRIBE_REQUEST

UNSUBSCRIBE_REQUEST

public static int UNSUBSCRIBE_REQUEST

Constructor Detail

JobStateMonitorSubscriptionManager

private JobStateMonitorSubscriptionManager()

Method Detail

getInstance

public static JobStateMonitorSubscriptionManager getInstance()

add

public void add(ManagedExecutableJobResource resource,
                int action)

terminate

public void terminate()

run

public void run()

subscribe

private void subscribe(ManagedExecutableJobResource resource)

unsubscribe

private void unsubscribe(ManagedExecutableJobResource resource)