de.ipcon.db.core

Class CachingBOLoaderLRUStrategy.ClassLimitedLRUContainer

java.lang.Object

de.ipcon.db.core.CachingBOLoaderLRUStrategy.ClassLimitedLRUContainer

All Implemented Interfaces:

CachingBOLoaderGCStrategyI, java.lang.Iterable<BO>, java.util.Iterator

Enclosing class:

CachingBOLoaderLRUStrategy

public static class CachingBOLoaderLRUStrategy.ClassLimitedLRUContainer
extends java.lang.Object
implements java.util.Iterator, CachingBOLoaderGCStrategyI

Field Summary

Fields

Modifier and Type	Field and Description
java.util.concurrent.atomic.AtomicInteger	cacheHit
java.util.concurrent.atomic.AtomicInteger	cacheMiss

Constructor Summary

Constructors

Constructor and Description
ClassLimitedLRUContainer(CachingBOLoader _boLoader, java.lang.Class[] limitToClasses, int[] _maxKeeps)

Method Summary

Modifier and Type	Method and Description
void	clear() Resets the caching strategy, e.g. because all cached objects have been dropped
CachingBOLoaderGCStrategyI	getStrategyFor(CachingBOLoader _boLoader, java.lang.Class[] limitToClasses, int[] maxKeepsPerClass)
boolean	hasNext()
boolean	isRelevant(BO bo)
java.util.Iterator	iterator() Resets the current iterator and returs this.
BO	next()
void	put(java.lang.Long k, BO v)
void	putAll(java.util.Map<java.lang.Long,BO> m) Called by the CachingBOLoader after new BOs have been inserted into the Cache, to allow the Strategy to add relevant root BOs to its internal structure.
void	remove()
void	rescheduleGC(int interval) Starts or stops a daemon, that clears the cache every interval seconds, but keeps a maximum number of instances of objects of types keepClasses specified in maxKeeps.
void	resetIterator()
void	setGCInterval(int interval)
void	stopAutoGC() Stops the daemon thread that automatically runs, if any.
void	updateLRU(java.lang.Object k)
void	updateOnCacheHit(BO bo) Called after a get or frap got a cache hit and did not need to put a new BO inside the cache.
void	updateWriteAccess(BO bo) Updates the caching strategy with a new 'written'/'added'/'coerced' time after a possibly existing BO would've been put into the cache again if it weren't already there yet.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface java.util.Iterator

forEachRemaining

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Detail

cacheHit

public java.util.concurrent.atomic.AtomicInteger cacheHit

cacheMiss

public java.util.concurrent.atomic.AtomicInteger cacheMiss

Constructor Detail

ClassLimitedLRUContainer

public ClassLimitedLRUContainer(CachingBOLoader _boLoader,
                                java.lang.Class[] limitToClasses,
                                int[] _maxKeeps)

Method Detail

getStrategyFor

public CachingBOLoaderGCStrategyI getStrategyFor(CachingBOLoader _boLoader,
                                                 java.lang.Class[] limitToClasses,
                                                 int[] maxKeepsPerClass)

clear

public void clear()

Description copied from interface: CachingBOLoaderGCStrategyI

Resets the caching strategy, e.g. because all cached objects have been dropped

Specified by:

clear in interface CachingBOLoaderGCStrategyI

isRelevant

public boolean isRelevant(BO bo)

putAll

public void putAll(java.util.Map<java.lang.Long,BO> m)

Description copied from interface: CachingBOLoaderGCStrategyI

Called by the CachingBOLoader after new BOs have been inserted into the Cache, to allow the Strategy to add relevant root BOs to its internal structure. The implementing class should decide by itself which provided BOs are relevant for its strategy. Will be called with a 'write lock' on the internal BO cache and prevents a parrallel gc() execution.

Specified by:

putAll in interface CachingBOLoaderGCStrategyI

Parameters:

m - the map of BOs that were just now added into the local cache, nonnull.

updateWriteAccess

public void updateWriteAccess(BO bo)

Description copied from interface: CachingBOLoaderGCStrategyI

Updates the caching strategy with a new 'written'/'added'/'coerced' time after a possibly existing BO would've been put into the cache again if it weren't already there yet.

Specified by:

updateWriteAccess in interface CachingBOLoaderGCStrategyI

updateLRU

public void updateLRU(java.lang.Object k)

put

public void put(java.lang.Long k,
                BO v)

Specified by:

put in interface CachingBOLoaderGCStrategyI

updateOnCacheHit

public void updateOnCacheHit(BO bo)

Description copied from interface: CachingBOLoaderGCStrategyI

Called after a get or frap got a cache hit and did not need to put a new BO inside the cache. Can be called asynchronously by different threads and might not have a write lock on the cache.

Specified by:

updateOnCacheHit in interface CachingBOLoaderGCStrategyI

iterator

public java.util.Iterator iterator()

Resets the current iterator and returs this. NOT thread safe. Only supports one Iterator at a time

Specified by:

iterator in interface java.lang.Iterable<BO>

resetIterator

public void resetIterator()

rescheduleGC

public void rescheduleGC(int interval)

Starts or stops a daemon, that clears the cache every interval seconds, but keeps a maximum number of instances of objects of types keepClasses specified in maxKeeps. If passed interval is negative, no daemon is started or it is asked to stop.

Specified by:

rescheduleGC in interface CachingBOLoaderGCStrategyI

setGCInterval

public void setGCInterval(int interval)

stopAutoGC

public void stopAutoGC()

Stops the daemon thread that automatically runs, if any.

Specified by:

stopAutoGC in interface CachingBOLoaderGCStrategyI

hasNext

public boolean hasNext()

Specified by:

hasNext in interface java.util.Iterator

next

public BO next()

Specified by:

next in interface java.util.Iterator

remove

public void remove()

Specified by:

remove in interface java.util.Iterator