|
Oracle® Coherence Java API Reference Release 3.7.1.0 E22843-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object
com.tangosol.util.Base
com.tangosol.util.Daemon
com.tangosol.io.journal.FlashJournalRM.PreparerDaemon
protected class FlashJournalRM.PreparerDaemon
The PreparerDaemon takes the enqueued Binary values for the JournalFile objects, and lays them out in Buffer objects from the BufferPool, enqueuing them for the WriterDaemon to write.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class com.tangosol.util.Daemon |
---|
Daemon.DaemonWorker |
Constructor Summary | |
---|---|
FlashJournalRM.PreparerDaemon() Construct a PreparerDaemon. |
Method Summary | |
---|---|
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. |
Methods inherited from class com.tangosol.util.Daemon |
---|
configureWorker, 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 |
Constructor Detail |
---|
public FlashJournalRM.PreparerDaemon()
Method Detail |
---|
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();
}
}
run
in interface java.lang.Runnable
run
in class Daemon
Thread.run()
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()
.stop
in class Daemon
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
|
Oracle® Coherence Java API Reference Release 3.7.1.0 E22843-01 |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |