protected class FlashJournalRM.PreparerDaemon extends Daemon
Daemon.DaemonWorker
Base.LoggingWriter, Base.StackFrame
Constructor and Description |
---|
PreparerDaemon()
Construct a PreparerDaemon.
|
Modifier and Type | Method and Description |
---|---|
protected void |
changeState(int nState, Daemon.DaemonWorker worker)
Change the state of the daemon.
|
protected Daemon.DaemonWorker |
instantiateWorker()
Instantiate a DaemonWorker that will be used as a daemon.
|
void |
notifyItemQueued(FlashJournalRM.JournalFile jrnlfile, long lTicket)
Notify the PreparerDaemon that an item has been queued to be written to the specified JournalFile.
|
void |
notifyJournalFileFull(FlashJournalRM.JournalFile jrnlfile)
Notify the PreparerDaemon that the specified JournalFile has been cut off for new additions.
|
void |
run()
The daemon's implementation method.
|
void |
stop()
Request the daemon to stop.
|
configureWorker, ensureThreadGroup, finishStarting, finishStopping, getConfiguredName, getConfiguredPriority, getContext, getDescription, getGuardRegisterAction, getMaxWaitMillis, getState, getThread, getThreadContextClassLoader, getWorker, guardIfNeeded, heartbeat, heartbeat, isGuarded, isOnWorkerThread, isRunning, isStopping, recover, setConfiguredName, setConfiguredPriority, setContext, setGuardPolicy, setGuardRegisterAction, setThreadContextClassLoader, shutdown, start, terminate, toStateString, toString
azzert, azzert, azzert, azzertFailed, breakLines, breakLines, capitalize, checkNotEmpty, checkNotNull, checkRange, computeSafeWaitTime, decimalValue, dup, dup, ensureBigDecimal, ensureClassLoader, ensureRuntimeException, ensureRuntimeException, equals, equalsDeep, err, err, err, err, err, escape, formatDateTime, getCallerStackFrame, getCommonMonitor, getCommonMonitor, getCommonMonitor, getContextClassLoader, getContextClassLoader, getDeepMessage, getErr, getLastSafeTimeMillis, getLog, getMaxDecDigits, getMaxHexDigits, getOriginalException, getOut, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mod, mod, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, randomize, randomize, read, read, read, read, read, read, read, replace, setErr, setLog, setLogEcho, setOut, sleep, toBandwidthString, toBandwidthString, toCharEscape, toCrc, toCrc, toCrc, toCrc, toCrc, toDecString, toDelimitedString, toDelimitedString, toDelimitedString, toDelimitedString, toHex, toHex, toHexDump, toHexEscape, toHexEscape, toHexEscape, toHexEscape, toHexString, toMemorySizeString, toMemorySizeString, toQuotedCharEscape, toQuotedStringEscape, toSqlString, toString, toString, toStringEscape, toUnicodeEscape, trace, trace, trace, trace, trace, trace, trace, trace, trace, truncateString, truncateString, wait
protected Daemon.DaemonWorker instantiateWorker()
instantiateWorker
in class Daemon
public void run()
An example implementation is:
while (!isStopping())
{
// do some processing
// ...
synchronized (this)
{
// wait for notification of more work
wait();
}
}
protected void changeState(int nState, Daemon.DaemonWorker worker)
changeState
in class Daemon
nState
- one of the STATE_enumsworker
- the new worker, if starting, otherwise the current workerpublic void stop()
Daemon.isStopping()
.public void notifyItemQueued(FlashJournalRM.JournalFile jrnlfile, long lTicket)
jrnlfile
- the JournalFile that is being appended tolTicket
- the ticket for the item that was queuedpublic void notifyJournalFileFull(FlashJournalRM.JournalFile jrnlfile)
jrnlfile
- the JournalFile that is now full