com.jn.langx.cache

类 AbstractCache<K,V>

java.lang.Object

com.jn.langx.cache.BaseCache<K,V>

com.jn.langx.cache.AbstractCache<K,V>

所有已实现的接口:

Cache<K,V>, Lifecycle

直接已知子类:

FIFOCache, LRUCache, SimpleCache

public abstract class AbstractCache<K,V>
extends BaseCache<K,V>

字段概要

从类继承的字段 com.jn.langx.cache.BaseCache

evictExpiredInterval, nextEvictExpiredTime, nextRefreshAllTime, refreshAllInterval, refreshAllTimeoutHolder, running, timer

构造器概要

构造器

限定符	构造器和说明
protected	AbstractCache(int maxCapacity, long evictExpiredInterval)
protected	AbstractCache(int maxCapacity, long evictExpiredInterval, long refreshAllInterval, Timer timer)
protected	AbstractCache(int maxCapacity, long evictExpiredInterval, Timer timer)

方法概要

限定符和类型	方法和说明
protected abstract void	addToCache(Entry<K,V> entry)
protected abstract void	afterRead(Entry<K,V> entry)
protected abstract void	afterRecomputeExpireTimeOnRead(Entry<K,V> entry)
protected abstract void	beforeRead(Entry<K,V> entry)
protected abstract void	beforeRecomputeExpireTimeOnRead(Entry<K,V> entry)
void	clean()
void	evictExpired()
protected abstract List<K>	forceEvict(int count) 用于找到将被强制清除的
V	get(K key) get by key
V	get(K key, Supplier<K,V> loader)
Map<K,V>	getAll(Iterable<K> keys) multiple get
Map<K,V>	getAllIfPresent(Iterable<K> keys) multiple get
V	getIfPresent(K key)
protected void	incrementUsedCount(Entry<K,V> entry)
Set<K>	keys()
void	refresh(K key)
protected void	refreshAllAsync(Timeout timeout)
List<V>	remove(Collection<K> keys)
V	remove(K key)
protected V	remove(K key, RemoveCause cause)
protected abstract void	removeFromCache(Entry<K,V> entry, RemoveCause removeCause)
void	set(K key, V value) set a key-value to cache, with out expire time never
void	set(K key, V value, long expire) set a key-value to cache, with the specified expire time
void	set(K key, V value, long duration, TimeUnit timeUnit) set a key-value to cache, with the specified expire time
protected void	setCapacityHeightWater(float capacityHeightWater)
protected void	setEvictExpiredInterval(long evictExpiredInterval)
protected void	setExpireAfterRead(long expireAfterRead)
protected void	setExpireAfterWrite(long expireAfterWrite)
protected void	setGlobalLoader(Loader<K,V> globalLoader)
void	setKeyReferenceType(ReferenceType keyReferenceType)
protected void	setMap(ConcurrentReferenceHashMap<K,Entry<K,V>> map)
protected void	setMaxCapacity(int maxCapacity)
void	setReferenceQueue(ReferenceQueue referenceQueue)
protected void	setRefreshAfterAccess(long refreshAfterAccess)
protected void	setRefreshAllInterval(long refreshAllInterval)
protected void	setRemoveListener(RemoveListener<K,V> removeListener)
void	setTimer(Timer timer)
void	setValueReferenceType(ReferenceType valueReferenceType)
int	size()
Map<K,V>	toMap()

从类继承的方法 com.jn.langx.cache.BaseCache

cancelRefreshAll, refreshAllAsync, setDistinctWhenRefresh, shutdown, startup

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

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

构造器详细资料

AbstractCache

protected AbstractCache(int maxCapacity,
                        long evictExpiredInterval)

AbstractCache

protected AbstractCache(int maxCapacity,
                        long evictExpiredInterval,
                        Timer timer)

AbstractCache

protected AbstractCache(int maxCapacity,
                        long evictExpiredInterval,
                        long refreshAllInterval,
                        Timer timer)

方法详细资料

setKeyReferenceType

public void setKeyReferenceType(ReferenceType keyReferenceType)

setValueReferenceType

public void setValueReferenceType(ReferenceType valueReferenceType)

setReferenceQueue

public void setReferenceQueue(ReferenceQueue referenceQueue)

set

public void set(@NonNull
                K key,
                @Nullable
                V value)

从接口复制的说明: Cache

set a key-value to cache, with out expire time never

参数:

key - the key

value - the value

set

public void set(@NonNull
                K key,
                @Nullable
                V value,
                long duration,
                TimeUnit timeUnit)

从接口复制的说明: Cache

set a key-value to cache, with the specified expire time

参数:

key - the key

value - the value

duration - the time-to-live time, the live time

set

public void set(@NonNull
                K key,
                @Nullable
                V value,
                long expire)

从接口复制的说明: Cache

set a key-value to cache, with the specified expire time

参数:

key - the key

value - the value

expire - the expire time

addToCache

protected abstract void addToCache(Entry<K,V> entry)

incrementUsedCount

protected void incrementUsedCount(Entry<K,V> entry)

get

public V get(@NonNull
             K key)

从接口复制的说明: Cache

get by key

参数:

key - the key

返回:

the value, null if key is not exist

getAll

public Map<K,V> getAll(Iterable<K> keys)

从接口复制的说明: Cache

multiple get

参数:

keys - get the specified keys

返回:

the values

getAllIfPresent

public Map<K,V> getAllIfPresent(Iterable<K> keys)

从接口复制的说明: Cache

multiple get

参数:

keys - get the specified keys

返回:

the values

getIfPresent

public V getIfPresent(@NonNull
                      K key)

get

public V get(@NonNull
             K key,
             @Nullable
             Supplier<K,V> loader)

beforeRecomputeExpireTimeOnRead

protected abstract void beforeRecomputeExpireTimeOnRead(Entry<K,V> entry)

afterRecomputeExpireTimeOnRead

protected abstract void afterRecomputeExpireTimeOnRead(Entry<K,V> entry)

refresh

public void refresh(@NonNull
                    K key)

refreshAllAsync

protected void refreshAllAsync(@Nullable
                               Timeout timeout)

覆盖:

refreshAllAsync 在类中 BaseCache<K,V>

参数:

timeout -

从以下版本开始:

4.0.4

removeFromCache

protected abstract void removeFromCache(Entry<K,V> entry,
                                        RemoveCause removeCause)

beforeRead

protected abstract void beforeRead(Entry<K,V> entry)

afterRead

protected abstract void afterRead(Entry<K,V> entry)

remove

protected final V remove(@NonNull
                         K key,
                         @NonNull
                         RemoveCause cause)

remove

public V remove(@NonNull
                K key)

remove

public List<V> remove(Collection<K> keys)

evictExpired

public void evictExpired()

forceEvict

protected abstract List<K> forceEvict(int count)

用于找到将被强制清除的

参数:

count - the count will be evicted

clean

public void clean()

size

public int size()

keys

public Set<K> keys()

从以下版本开始:

4.0.4

toMap

public Map<K,V> toMap()

setMap

protected void setMap(ConcurrentReferenceHashMap<K,Entry<K,V>> map)

setGlobalLoader

protected void setGlobalLoader(Loader<K,V> globalLoader)

setExpireAfterWrite

protected void setExpireAfterWrite(long expireAfterWrite)

setExpireAfterRead

protected void setExpireAfterRead(long expireAfterRead)

setEvictExpiredInterval

protected void setEvictExpiredInterval(long evictExpiredInterval)

setRemoveListener

protected void setRemoveListener(RemoveListener<K,V> removeListener)

setMaxCapacity

protected void setMaxCapacity(int maxCapacity)

setCapacityHeightWater

protected void setCapacityHeightWater(float capacityHeightWater)

setRefreshAfterAccess

protected void setRefreshAfterAccess(long refreshAfterAccess)

setRefreshAllInterval

protected void setRefreshAllInterval(long refreshAllInterval)

setTimer

public void setTimer(Timer timer)