Package com.tangosol.net.cache

Class AbstractKeyBundler.Bundle

java.lang.Object

com.tangosol.util.Base

com.tangosol.net.cache.AbstractBundler.Bundle

com.tangosol.net.cache.AbstractKeyBundler.Bundle

Enclosing class:

AbstractKeyBundler

protected class AbstractKeyBundler.Bundle
extends AbstractBundler.Bundle

Bundle represents a unit of optimized execution.

Nested Class Summary

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

Base.LoggingWriter

Field Summary

Fields inherited from class com.tangosol.net.cache.AbstractBundler.Bundle

STATUS_EXCEPTION, STATUS_OPEN, STATUS_PENDING, STATUS_PROCESSED

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

Modifier	Constructor	Description
protected	Bundle()	Default constructor.

Method Summary

Modifier and Type	Method	Description
protected boolean	add(Object oKey)	Add the specified key to the Bundle.
protected boolean	addAll(Collection colKeys)	Add the specified collection of keys to the Bundle.
protected void	ensureResults()	Obtain results of the bundled requests.
protected int	getBundleSize()	Obtain this bundle size.
protected Object	process(boolean fBurst, Object oKey)	Process the specified key according to this Bundle state.
protected Map	processAll(boolean fBurst, Collection colKeys)	Process the specified key collection according to this Bundle state.
protected boolean	releaseThread()	Release all bundle resources associated with the current thread.

Methods inherited from class com.tangosol.net.cache.AbstractBundler.Bundle

ensureResults, formatStatusName, isException, isMaster, isOpen, isPending, isProcessed, resetStatistics, setMaster, setStatus, toString, waitForResults

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

Constructor Details

Bundle

protected Bundle()

Default constructor.

Method Details

add

protected boolean add(Object oKey)

Add the specified key to the Bundle.

Note: a call to this method must be externally synchronized for this Bundle object.

Parameters:

oKey - the key to add to this Bundle

Returns:

true if this Bundle was empty prior to this call

addAll

protected boolean addAll(Collection colKeys)

Add the specified collection of keys to the Bundle.

Note: a call to this method must be externally synchronized for this Bundle object.

Parameters:

colKeys - the collection of keys to add to this Bundle

Returns:

true if this Bundle was empty prior to this call

process

protected Object process(boolean fBurst,
 Object oKey)

Process the specified key according to this Bundle state.

Parameters:

fBurst - true if this thread is supposed to perform an actual bundled operation (burst); false otherwise

oKey - the key to process

Returns:

an execution result according to the caller's contract

processAll

protected Map processAll(boolean fBurst,
 Collection colKeys)

Process the specified key collection according to this Bundle state.

Parameters:

fBurst - true if this thread is supposed to perform an actual bundled operation (burst); false otherwise

colKeys - the collection of keys to process

Returns:

an execution result according to the caller's contract

getBundleSize

protected int getBundleSize()

Obtain this bundle size. The return value should be expressed in the same units as the value returned by the getSizeThreshold method.

Overrides:

getBundleSize in class AbstractBundler.Bundle

Returns:

the bundle size

ensureResults

protected void ensureResults()

Obtain results of the bundled requests. This method should be implemented by concrete Bundle implementations using the most efficient mechanism.

Specified by:

ensureResults in class AbstractBundler.Bundle

releaseThread

protected boolean releaseThread()

Release all bundle resources associated with the current thread.

Overrides:

releaseThread in class AbstractBundler.Bundle

Returns:

true iff all entered threads have released