|
CoherenceTM v3.3 Copyright© 2000-2007 by Oracle Corporation |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.tangosol.util.Base
com.tangosol.util.Daemon
com.tangosol.io.AsyncBinaryStore.QueueDaemon
protected class AsyncBinaryStore.QueueDaemon
A daemon that processes queued writes.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class com.tangosol.util.Daemon |
---|
Daemon.DaemonWorker |
Constructor Summary | |
---|---|
AsyncBinaryStore.QueueDaemon()
Construct a queue daemon to process pending writes. |
Method Summary | |
---|---|
boolean |
isDone()
Determine if the daemon thread should continue processing or should shut itself down. |
protected boolean |
isDormant()
Determine whether the daemon is dormant or not. |
protected void |
processPending(Binary binKey,
Binary binValue)
Store the specified value under the specific key in the underlying store, or if the value is AsyncBinaryStore.DELETED then erase
the value from the underlying store. |
void |
run()
This method is invoked on the daemon thread and performs the daemon processing until the thread stops. |
void |
scheduleWork()
Notify the daemon that there is work to be done. |
protected void |
setDormant(boolean fDormant)
Specify whether the daemon is dormant or not. |
protected void |
takeBreak()
Take a short break before plowing into the pending work again. |
protected void |
takeNap()
Take a nap before checking for more pending work. |
protected void |
takeVacation()
Go on an extended vacation until there is any pending work. |
void |
wakeNow()
Force the daemon to wake up immediately. |
Methods inherited from class com.tangosol.util.Daemon |
---|
changeState, configureWorker, getConfiguredName, getConfiguredPriority, getDescription, getState, getThread, getThreadContextClassLoader, getWorker, instantiateWorker, isOnWorkerThread, isRunning, isStopping, setConfiguredName, setConfiguredPriority, setThreadContextClassLoader, start, stop, toStateString, toString |
Constructor Detail |
---|
public AsyncBinaryStore.QueueDaemon()
Method Detail |
---|
public void scheduleWork()
public void wakeNow()
public boolean isDone()
public void run()
run
in interface Runnable
run
in class Daemon
protected void processPending(Binary binKey, Binary binValue)
AsyncBinaryStore.DELETED
then erase
the value from the underlying store.
binKey
- key to store the value underbinValue
- value to be storedprotected void takeBreak()
protected void takeNap()
protected void takeVacation()
protected boolean isDormant()
protected void setDormant(boolean fDormant)
fDormant
- pass true if the daemon is going dormant, or false
if the daemon is waking up from a dormant state
|
CoherenceTM v3.3 Copyright© 2000-2007 by Oracle Corporation |
|||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |