cn.weforward.data.persister.support

类 PersistentCache<E extends Persistent>

java.lang.Object

cn.weforward.common.util.LruHashMap<K,V>

cn.weforward.common.util.LruCache<String,E>

cn.weforward.data.persister.support.PersistentCache<E>

类型参数:

E - 可持久化对象

所有已实现的接口:

cn.weforward.common.GcCleanable, Iterable<cn.weforward.common.KvPair<String,E>>

直接已知子类:

AbstractPersister.Cache

public abstract class PersistentCache<E extends Persistent>
extends cn.weforward.common.util.LruCache<String,E>

用于支撑持久化对象的缓冲

作者:

liangyi

嵌套类概要

嵌套类

限定符和类型	类和说明
protected class	PersistentCache.PersistNode

从类继承的嵌套类/接口 cn.weforward.common.util.LruCache

cn.weforward.common.util.LruCache.CacheNode<K,V>, cn.weforward.common.util.LruCache.CopyOn, cn.weforward.common.util.LruCache.Direct, cn.weforward.common.util.LruCache.DirtyData<V>, cn.weforward.common.util.LruCache.Loader<K,V>, cn.weforward.common.util.LruCache.Updater<K,V>

从类继承的嵌套类/接口 cn.weforward.common.util.LruHashMap

cn.weforward.common.util.LruHashMap.Node<K,V>

字段概要

字段

限定符和类型	字段和说明
static String	VERSION_UPDATING 标示正处理更新中，这种状态下的版本号可认为是相同的

从类继承的字段 cn.weforward.common.util.LruCache

_clock, _dirty, _emptyDirtyData, _pending, _unassigned, m_GetCount, m_LoadConcurrent, m_LoadCount, m_MaxLoadConcurrent, m_Name, m_NullTimeout, m_Options, m_PendingTimeout, m_Timeout, m_UpdatedChain, OPTION_REACHABLE, POLICY_GC_FORWARD

从类继承的字段 cn.weforward.common.util.LruHashMap

_Logger, m_Height, m_LoadFactor, m_LruHead, m_LruTail, m_MaxCapacity, m_ModCount, m_Size, m_Table, m_Threshold

从接口继承的字段 cn.weforward.common.GcCleanable

POLICY_CRITICAL, POLICY_IDLE, POLICY_LOW, POLICY_MAINTAIN, POLICY_MASK, POLICY_OPTIMIZE

构造器概要

构造器

构造器和说明
PersistentCache(String name)

方法概要

限定符和类型	方法和说明
protected void	afterNodeRemoval(cn.weforward.common.util.LruHashMap.Node<String,E> p)
protected void	afterNodeUpdate(cn.weforward.common.util.LruHashMap.Node<String,E> p)
protected PersistentCache.PersistNode	flush(E object)
protected PersistentCache.PersistNode	getNode(int hash, Object key)
int	getNullTimeout()
String	getVersion(String ordinal)
boolean	isDirty(String ordinal)
protected abstract String	newer(E object) 标记（可能是）新的持久化对象（用于对象未刷写前能进行查询）
protected PersistentCache.PersistNode	newNode(int hash, String key, E value, cn.weforward.common.util.LruHashMap.Node<String,E> next)
protected PersistentCache.PersistNode	openNode(int hash, String key)
protected abstract String	persist(E object, PersistentCache.PersistNode node) 把对象持久化
String	updateVersion(String ordinal, E value, String version) 更新若缓存项的版本号
protected PersistentCache.PersistNode	updating(E object) 把状态变化对象置入缓存

从类继承的方法 cn.weforward.common.util.LruCache

afterNodeAccess, afterNodeLoad, getAndLoad, getDirtyData, getHintLoad, getHintLoad, getHitRate, getLruHead, getMaxLoadConcurrent, getName, getPendingTimeout, getTimeout, idleTrim, markUpdated, onGcCleanup, setMaxLoadConcurrent, setName, setNullTimeout, setPendingTimeout, setReachable, setTimeout, toString, trim, trimClean, update, updatedLock

从类继承的方法 cn.weforward.common.util.LruHashMap

afterNodeInsertion, clear, fixLru, get, getMaxCapacity, getOrDefault, hash, initLru, isLruEmpty, iterator, lru, lruLock, pinch, put, putIfAbsent, putLru, rebuild, remove, remove, removeAll, removeLru, resize, setMaxCapacity, size, tableLock, tableSizeFor

从类继承的方法 java.lang.Object

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

从接口继承的方法 java.lang.Iterable

forEach, spliterator

字段详细资料

VERSION_UPDATING

public static final String VERSION_UPDATING

标示正处理更新中，这种状态下的版本号可认为是相同的

另请参阅:

常量字段值

构造器详细资料

PersistentCache

public PersistentCache(String name)

方法详细资料

getNullTimeout

public int getNullTimeout()

覆盖:

getNullTimeout 在类中 cn.weforward.common.util.LruCache<String,E extends Persistent>

persist

protected abstract String persist(E object,
                                  PersistentCache.PersistNode node)

把对象持久化

参数:

object - 要持久化的对象

node - 对应的缓存节点

返回:

持久化后的版本号

newer

protected abstract String newer(E object)

标记（可能是）新的持久化对象（用于对象未刷写前能进行查询）

参数:

object - （可能是）新的持久化对象

返回:

持久化后的版本号

openNode

protected PersistentCache.PersistNode openNode(int hash,
                                               String key)

覆盖:

openNode 在类中 cn.weforward.common.util.LruCache<String,E extends Persistent>

getNode

protected PersistentCache.PersistNode getNode(int hash,
                                              Object key)

覆盖:

getNode 在类中 cn.weforward.common.util.LruCache<String,E extends Persistent>

newNode

protected PersistentCache.PersistNode newNode(int hash,
                                              String key,
                                              E value,
                                              cn.weforward.common.util.LruHashMap.Node<String,E> next)

覆盖:

newNode 在类中 cn.weforward.common.util.LruCache<String,E extends Persistent>

isDirty

public boolean isDirty(String ordinal)

getVersion

public String getVersion(String ordinal)

updateVersion

public String updateVersion(String ordinal,
                            E value,
                            String version)

更新若缓存项的版本号

参数:

ordinal - 缓存项标识

value - 对象

version - 要更新到的版本号

返回:

旧版本号

updating

protected PersistentCache.PersistNode updating(E object)

把状态变化对象置入缓存

参数:

object - 状态变化的对象

返回:

缓存节点

afterNodeUpdate

protected void afterNodeUpdate(cn.weforward.common.util.LruHashMap.Node<String,E> p)

覆盖:

afterNodeUpdate 在类中 cn.weforward.common.util.LruCache<String,E extends Persistent>

afterNodeRemoval

protected void afterNodeRemoval(cn.weforward.common.util.LruHashMap.Node<String,E> p)

覆盖:

afterNodeRemoval 在类中 cn.weforward.common.util.LruCache<String,E extends Persistent>

flush

protected PersistentCache.PersistNode flush(E object)