public class CyclicBufferTracker<E> extends AbstractComponentTracker<CyclicBuffer<E>>
CyclicBuffer instances.| Modifier and Type | Field and Description |
|---|---|
(package private) int |
bufferSize |
(package private) static int |
DEFAULT_BUFFER_SIZE |
(package private) static int |
DEFAULT_NUMBER_OF_BUFFERS |
lastCheck, lingerersMap, LINGERING_TIMEOUT, liveMap, maxComponents, timeout, WAIT_BETWEEN_SUCCESSIVE_REMOVAL_ITERATIONSDEFAULT_MAX_COMPONENTS, DEFAULT_TIMEOUT| Constructor and Description |
|---|
CyclicBufferTracker() |
| Modifier and Type | Method and Description |
|---|---|
protected CyclicBuffer<E> |
buildComponent(java.lang.String key)
Build a component based on the key.
|
int |
getBufferSize() |
protected boolean |
isComponentStale(CyclicBuffer<E> eCyclicBuffer)
Components can declare themselves stale.
|
(package private) java.util.List<java.lang.String> |
lingererKeysAsOrderedList() |
(package private) java.util.List<java.lang.String> |
liveKeysAsOrderedList() |
protected void |
processPriorToRemoval(CyclicBuffer<E> component)
Stop or clean the component.
|
void |
setBufferSize(int bufferSize) |
allComponents, allKeys, endOfLife, find, getComponentCount, getMaxComponents, getOrCreate, getTimeout, removeStaleComponents, setMaxComponents, setTimeoutstatic final int DEFAULT_NUMBER_OF_BUFFERS
static final int DEFAULT_BUFFER_SIZE
int bufferSize
public int getBufferSize()
public void setBufferSize(int bufferSize)
protected void processPriorToRemoval(CyclicBuffer<E> component)
AbstractComponentTrackerprocessPriorToRemoval in class AbstractComponentTracker<CyclicBuffer<E>>protected CyclicBuffer<E> buildComponent(java.lang.String key)
AbstractComponentTrackerbuildComponent in class AbstractComponentTracker<CyclicBuffer<E>>protected boolean isComponentStale(CyclicBuffer<E> eCyclicBuffer)
AbstractComponentTrackerisComponentStale in class AbstractComponentTracker<CyclicBuffer<E>>java.util.List<java.lang.String> liveKeysAsOrderedList()
java.util.List<java.lang.String> lingererKeysAsOrderedList()