org.globus.cog.karajan.workflow.events
Class EventBus.CriticalEventBus
java.lang.Object
java.lang.Thread
org.globus.cog.karajan.workflow.events.EventBus
org.globus.cog.karajan.workflow.events.EventBus.CriticalEventBus
- All Implemented Interfaces:
- Runnable
- Enclosing class:
- EventBus
- public static final class EventBus.CriticalEventBus
- extends EventBus
| Fields inherited from class org.globus.cog.karajan.workflow.events.EventBus |
countThreshold, cummulativeEventTime, DEFAULT_COUNT_THRESHOLD, DEFAULT_MAX_SEND_TIME, DEFAULT_MIN_CRITICAL_THREADS, endEvents, MAX_QUEUED_EVENTS, maxCriticalThreads, maxSendTime, minCriticalThreads, startEvents |
| Methods inherited from class org.globus.cog.karajan.workflow.events.EventBus |
addCriticalBus, dequeue, getAllEvents, getCountThreshold, getCurrentCriticalThreads, getEvents, getMaxSendTime, getMinCriticalThreads, getQueueSize, initialize, initializeCriticalThreads, isInitialized, isSleeping, isSuspended, isTerminateOnEmptyQueue, newEventBus, post, postT, removeCriticalBus, removeEventHook, resumeAll, resumeAll, resumeT, run, send, setCountThreshold, setEventHook, setMaxSendTime, setMinCriticalThreads, setTerminateOnEmptyQueue, shutdown, shutdownT, suspendAll, suspendAll, suspendT, waitForEvents |
| 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, yield |
EventBus.CriticalEventBus
public EventBus.CriticalEventBus()
sendT
protected void sendT(EventListener fel,
Event fee)
- Overrides:
sendT in class EventBus
getLastSendStart
public long getLastSendStart()
toString
public String toString()
isBlocked
public boolean isBlocked()
setBlocked
public void setBlocked(boolean blocked)