Package com.github.benmanes.caffeine.cache

Class LocalCacheFactory.WILiSW<K,V>

java.lang.Object

java.util.AbstractMap<K,V>

com.github.benmanes.caffeine.cache.BLCHeader.PadDrainStatus<K,V>

com.github.benmanes.caffeine.cache.BLCHeader.DrainStatusRef<K,V>

com.github.benmanes.caffeine.cache.BoundedLocalCache<K,V>

com.github.benmanes.caffeine.cache.LocalCacheFactory.WI<K,V>

com.github.benmanes.caffeine.cache.LocalCacheFactory.WILi<K,V>

com.github.benmanes.caffeine.cache.LocalCacheFactory.WILiS<K,V>

com.github.benmanes.caffeine.cache.LocalCacheFactory.WILiSW<K,V>

All Implemented Interfaces:

LocalCache<K,V>, java.util.concurrent.ConcurrentMap<K,V>, java.util.Map<K,V>

Direct Known Subclasses:

LocalCacheFactory.WILiSWR

Enclosing class:

LocalCacheFactory

static class LocalCacheFactory.WILiSW<K,V>
extends LocalCacheFactory.WILiS<K,V>

Nested Class Summary

Nested classes/interfaces inherited from class com.github.benmanes.caffeine.cache.BoundedLocalCache

BoundedLocalCache.AddTask, BoundedLocalCache.BoundedLocalAsyncLoadingCache<K,V>, BoundedLocalCache.BoundedLocalLoadingCache<K,V>, BoundedLocalCache.BoundedLocalManualCache<K,V>, BoundedLocalCache.BoundedPolicy<K,V>, BoundedLocalCache.EntryIterator<K,V>, BoundedLocalCache.EntrySetView<K,V>, BoundedLocalCache.EntrySpliterator<K,V>, BoundedLocalCache.KeyIterator<K,V>, BoundedLocalCache.KeySetView<K,V>, BoundedLocalCache.KeySpliterator<K,V>, BoundedLocalCache.PerformCleanupTask, BoundedLocalCache.RemovalTask, BoundedLocalCache.UpdateTask, BoundedLocalCache.ValueIterator<K,V>, BoundedLocalCache.ValueSpliterator<K,V>, BoundedLocalCache.ValuesView<K,V>

Nested classes/interfaces inherited from class java.util.AbstractMap

java.util.AbstractMap.SimpleEntry<K extends java.lang.Object,V extends java.lang.Object>, java.util.AbstractMap.SimpleImmutableEntry<K extends java.lang.Object,V extends java.lang.Object>

Nested classes/interfaces inherited from interface java.util.Map

java.util.Map.Entry<K extends java.lang.Object,V extends java.lang.Object>

Field Summary

Fields

Modifier and Type	Field	Description
private long	expiresAfterWriteNanos
private Ticker	ticker
private MpscGrowableArrayQueue<java.lang.Runnable>	writeBuffer
private WriteOrderDeque<Node<K,V>>	writeOrderDeque

Fields inherited from class com.github.benmanes.caffeine.cache.BoundedLocalCache

accessPolicy, cacheLoader, data, drainBuffersTask, entrySet, evictionLock, executor, EXPIRE_WRITE_TOLERANCE, isAsync, keySet, logger, MAXIMUM_CAPACITY, NCPU, nodeFactory, PERCENT_MAIN, PERCENT_MAIN_PROTECTED, readBuffer, values, weigher, WRITE_BUFFER_MAX, WRITE_BUFFER_MIN, WRITE_BUFFER_RETRIES, writer

Fields inherited from class com.github.benmanes.caffeine.cache.BLCHeader.DrainStatusRef

DRAIN_STATUS_OFFSET, drainStatus, IDLE, PROCESSING_TO_IDLE, PROCESSING_TO_REQUIRED, REQUIRED

Fields inherited from class com.github.benmanes.caffeine.cache.BLCHeader.PadDrainStatus

p00, p01, p02, p03, p04, p05, p06, p07, p10, p11, p12, p13, p14, p15, p16

Constructor Summary

Constructors

Constructor	Description
WILiSW(Caffeine<K,V> builder, CacheLoader<? super K,V> cacheLoader, boolean async)

Method Summary

Modifier and Type	Method	Description
protected boolean	buffersWrites()	If the page replacement policy buffers writes.
Ticker	expirationTicker()	Returns the Ticker used by this cache for expiration.
protected boolean	expiresAfterWrite()	Returns if the cache expires entries after an write time threshold.
protected long	expiresAfterWriteNanos()	How long after the last write to an entry the map will retain that entry.
protected void	setExpiresAfterWriteNanos(long expiresAfterWriteNanos)
protected MpscGrowableArrayQueue<java.lang.Runnable>	writeBuffer()
protected WriteOrderDeque<Node<K,V>>	writeOrderDeque()

Methods inherited from class com.github.benmanes.caffeine.cache.LocalCacheFactory.WILiS

isRecordingStats, statsCounter, statsTicker

Methods inherited from class com.github.benmanes.caffeine.cache.LocalCacheFactory.WILi

hasRemovalListener, removalListener

Methods inherited from class com.github.benmanes.caffeine.cache.LocalCacheFactory.WI

collectKeys, collectValues, keyReferenceQueue, valueReferenceQueue

Methods inherited from class com.github.benmanes.caffeine.cache.BoundedLocalCache

accessOrderEdenDeque, accessOrderProbationDeque, accessOrderProtectedDeque, adjustedWeightedSize, admit, afterRead, afterWrite, ceilingPowerOfTwo, cleanUp, clear, compute, computeIfAbsent, computeIfPresent, containsKey, containsValue, doComputeIfAbsent, drainKeyReferences, drainReadBuffer, drainValueReferences, drainWriteBuffer, edenMaximum, edenWeightedSize, entrySet, estimatedSize, evictEntries, evictEntry, evictFromEden, evictFromMain, evictionOrder, evicts, executor, expireAfterAccessEntries, expireAfterAccessEntries, expireAfterAcessOrder, expireAfterWriteEntries, expireAfterWriteOrder, expireEntries, expiresAfterAccess, expiresAfterAccessNanos, fastpath, frequencySketch, get, getAllPresent, getIfPresent, getIfPresentQuietly, hasExpired, hasWriter, hasWriteTime, isComputingAsync, isEmpty, isWeighted, keySet, lazySetEdenMaximum, lazySetEdenWeightedSize, lazySetMainProtectedMaximum, lazySetMainProtectedWeightedSize, lazySetMaximum, lazySetWeightedSize, mainProtectedMaximum, mainProtectedWeightedSize, maintenance, makeDead, makeSerializationProxy, maximum, merge, notifyRemoval, onAccess, performCleanUp, put, put, putFast, putIfAbsent, putSlow, refreshAfterWrite, refreshAfterWriteNanos, refreshIfNeeded, remap, remove, remove, removeNode, removeNodes, removeNoWriter, removeWithWriter, reorder, reorderProbation, replace, replace, replaceAll, scheduleAfterWrite, scheduleDrainBuffers, setExpiresAfterAccessNanos, setMaximum, setRefreshAfterWriteNanos, size, skipReadBuffer, snapshot, values, weightedSize

Methods inherited from class com.github.benmanes.caffeine.cache.BLCHeader.DrainStatusRef

casDrainStatus, drainStatus, lazySetDrainStatus, shouldDrainBuffers

Methods inherited from class java.util.AbstractMap

clone, equals, hashCode, putAll, toString

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.ConcurrentMap

forEach, getOrDefault

Methods inherited from interface com.github.benmanes.caffeine.cache.LocalCache

compute, computeIfAbsent, invalidateAll, statsAware, statsAware, statsAware

Methods inherited from interface java.util.Map

equals, hashCode, putAll

Field Detail

ticker

private final Ticker ticker

writeOrderDeque

private final WriteOrderDeque<Node<K,V>> writeOrderDeque

expiresAfterWriteNanos

private volatile long expiresAfterWriteNanos

writeBuffer

private final MpscGrowableArrayQueue<java.lang.Runnable> writeBuffer

Constructor Detail

WILiSW

WILiSW(Caffeine<K,V> builder,
       CacheLoader<? super K,V> cacheLoader,
       boolean async)

Method Detail

expirationTicker

public final Ticker expirationTicker()

Description copied from interface: LocalCache

Returns the Ticker used by this cache for expiration.

Specified by:

expirationTicker in interface LocalCache<K,V>

Overrides:

expirationTicker in class BoundedLocalCache<K,V>

writeOrderDeque

protected final WriteOrderDeque<Node<K,V>> writeOrderDeque()

Overrides:

writeOrderDeque in class BoundedLocalCache<K,V>

expiresAfterWrite

protected final boolean expiresAfterWrite()

Description copied from class: BoundedLocalCache

Returns if the cache expires entries after an write time threshold.

Overrides:

expiresAfterWrite in class BoundedLocalCache<K,V>

expiresAfterWriteNanos

protected final long expiresAfterWriteNanos()

Description copied from class: BoundedLocalCache

How long after the last write to an entry the map will retain that entry.

Overrides:

expiresAfterWriteNanos in class BoundedLocalCache<K,V>

setExpiresAfterWriteNanos

protected final void setExpiresAfterWriteNanos(long expiresAfterWriteNanos)

Overrides:

setExpiresAfterWriteNanos in class BoundedLocalCache<K,V>

writeBuffer

protected final MpscGrowableArrayQueue<java.lang.Runnable> writeBuffer()

Overrides:

writeBuffer in class BoundedLocalCache<K,V>

buffersWrites

protected final boolean buffersWrites()

Description copied from class: BoundedLocalCache

If the page replacement policy buffers writes.

Overrides:

buffersWrites in class BoundedLocalCache<K,V>