I2PThread.OOMEventListenerThread.State, Thread.UncaughtExceptionHandlerMAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY| Constructor and Description |
|---|
JobQueueRunner(RouterContext context,
int id)Create a new job queue runner. |
| Modifier and Type | Method and Description |
|---|---|
Job | getCurrentJob()The job currently being executed. |
long | getLastBegin()Time the last job began. |
long | getLastEnd()Time the last job ended. |
Job | getLastJob()The most recently completed job. |
int | getRunnerId()Identifier for this runner. |
void | run()Run the thread, catching and reporting OOM and other failures. |
void | startRunning()Start the runner. |
void | stopRunning()Stop the runner. |
addOOMEventListener, fireOOM, removeOOMEventListener, startactiveCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, stop, stop, suspend, toString, yieldpublic JobQueueRunner(RouterContext context, int id)
context - the router contextid - the runner idpublic Job getCurrentJob()
public long getLastBegin()
public long getLastEnd()
public Job getLastJob()
public int getRunnerId()
public void run()
I2PThreadpublic void startRunning()
public void stopRunning()