Skip navigation links

Oracle® Coherence Java API Reference
Release 3.7.0.0

E18683-01


com.tangosol.net.cache
Class AbstractKeyBundler.Bundle

java.lang.Object
  extended by com.tangosol.util.Base
      extended by com.tangosol.net.cache.AbstractBundler.Bundle
          extended by com.tangosol.net.cache.AbstractKeyBundler.Bundle

Enclosing class:
AbstractKeyBundler

protected class AbstractKeyBundler.Bundle
extends AbstractBundler.Bundle

Field Summary

 

Fields inherited from class com.tangosol.net.cache.AbstractBundler.Bundle
STATUS_EXCEPTION, STATUS_OPEN, STATUS_PENDING, STATUS_PROCESSED

 

Constructor Summary
protected AbstractKeyBundler.Bundle()
          Default constructor.

 

Method Summary
protected  boolean add(java.lang.Object oKey)
          Add the specified key to the Bundle.
protected  boolean addAll(java.util.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  java.lang.Object process(boolean fBurst, java.lang.Object oKey)
          Process the specified key according to this Bundle state.
protected  java.util.Map processAll(boolean fBurst, java.util.Collection colKeys)
          Process the specified kye 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

 

Constructor Detail

AbstractKeyBundler.Bundle

protected AbstractKeyBundler.Bundle()
Default constructor.

Method Detail

add

protected boolean add(java.lang.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(java.util.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 java.lang.Object process(boolean fBurst,
                                   java.lang.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 java.util.Map processAll(boolean fBurst,
                                   java.util.Collection colKeys)
Process the specified kye 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

Skip navigation links

Oracle® Coherence Java API Reference
Release 3.7.0.0

E18683-01


Copyright © 2000, 2011, Oracle and/or its affiliates. All rights reserved.