Package com.tangosol.net.cache

Class ReadWriteBackingMap.ReadThread

java.lang.Object

com.tangosol.util.Base

com.tangosol.util.Daemon

com.tangosol.net.cache.ReadWriteBackingMap.ReadThread

All Implemented Interfaces:

Guardable, Runnable

Enclosing class:

ReadWriteBackingMap

public class ReadWriteBackingMap.ReadThread
extends Daemon

A thread that removes keys from a ReadWriteBackingMap.ReadQueue, reads the value for the key from the underlying CacheStore, and caches the value in the internal ReadWriteBackingMap cache.

Author:

jh 2005.02.08

Nested Class Summary

Nested classes/interfaces inherited from class com.tangosol.util.Daemon

Daemon.DaemonWorker

Nested classes/interfaces inherited from class com.tangosol.util.Base

Base.LoggingWriter

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	m_fRefreshContext	Field used to tell the ReadWriteBackingMap.ReadThread to refresh its Guardian.GuardContext.

Fields inherited from class com.tangosol.util.Base

DEFAULT_LOAD_FACTOR, LOG_ALWAYS, LOG_CONFIG, LOG_DEBUG, LOG_ERR, LOG_INFO, LOG_MAX, LOG_MIN, LOG_QUIET, LOG_WARN, POWER_0, POWER_G, POWER_K, POWER_M, POWER_T, UNIT_D, UNIT_H, UNIT_M, UNIT_MS, UNIT_NS, UNIT_S, UNIT_US

Constructor Summary

Constructors

Constructor	Description
ReadThread()	Default constructor.

Method Summary

Modifier and Type	Method	Description
void	run()	The daemon's implementation method.
protected void	setGuardPolicy(Guardian guardian, long cTimeoutMillis, float flPctRecover)	Set the Guardian and policy to guard this Daemon with.
void	terminate()	Terminate this Guardable.

Methods inherited from class com.tangosol.util.Daemon

changeState, configureWorker, ensureThreadGroup, finishStarting, finishStopping, getConfiguredName, getConfiguredPriority, getContext, getDescription, getGuardRegisterAction, getMaxWaitMillis, getState, getThread, getThreadContextClassLoader, getWorker, guardIfNeeded, heartbeat, heartbeat, instantiateWorker, isGuarded, isOnWorkerThread, isRunning, isStopping, recover, setConfiguredName, setConfiguredPriority, setContext, setGuardRegisterAction, setThreadContextClassLoader, shutdown, start, stop, toStateString, toString

Methods inherited from class com.tangosol.util.Base

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, getProcessRandom, getRandom, getRandomBinary, getRandomBinary, getRandomString, getSafeTimeMillis, getStackFrame, getStackFrames, getStackTrace, getStackTrace, getStackTrace, getThreadFactory, getTimeZone, getUpTimeMillis, hashCode, hexValue, indentString, indentString, isDecimal, isHex, isLogEcho, isOctal, log, log, log, log, log, makeInteger, makeLong, makeThread, mergeArray, mergeBooleanArray, mergeByteArray, mergeCharArray, mergeDoubleArray, mergeFloatArray, mergeIntArray, mergeLongArray, mod, mod, newHashMap, newHashMap, newHashSet, newHashSet, octalValue, out, out, out, out, out, pad, parseBandwidth, parseBandwidth, parseDelimitedString, parseHex, parseHex, parseMemorySize, parseMemorySize, parsePercentage, parseTime, parseTime, parseTimeNanos, parseTimeNanos, printStackTrace, randomize, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details

m_fRefreshContext

protected volatile boolean m_fRefreshContext

Field used to tell the ReadWriteBackingMap.ReadThread to refresh its Guardian.GuardContext.

Constructor Details

ReadThread

public ReadThread()

Default constructor.

Method Details

run

public void run()

The daemon's implementation method.

Specified by:

run in interface Runnable

Specified by:

run in class Daemon

terminate

public void terminate()

Terminate this Guardable.

This is the final action taken by the Guardian before the Guardable is removed from its responsibility list.

Specified by:

terminate in interface Guardable

Overrides:

terminate in class Daemon

setGuardPolicy

protected void setGuardPolicy(Guardian guardian,
 long cTimeoutMillis,
 float flPctRecover)

Set the Guardian and policy to guard this Daemon with. The Daemon is registered with the specified Guardian each time the Daemon is started, and is released each time the Daemon is stopped.

Overrides:

setGuardPolicy in class Daemon

Parameters:

guardian - the Guardian that will be guarding this Daemon

cTimeoutMillis - the timeout in ms for this Daemon, or 0 for the service guardian timeout

flPctRecover - the recovery percentage for this Daemon