Class BoundedLocalCache.BoundedLocalAsyncLoadingCache<K,V>

java.lang.Object

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

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

All Implemented Interfaces:

AsyncCache<K,V>, AsyncLoadingCache<K,V>, LocalAsyncCache<K,V>, Serializable

Enclosing class:

BoundedLocalCache<K,V>

static final class BoundedLocalCache.BoundedLocalAsyncLoadingCache<K,V>
extends LocalAsyncLoadingCache<K,V>
implements Serializable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	BoundedLocalCache.BoundedLocalAsyncLoadingCache.AsyncLoader<K,V>

Nested classes/interfaces inherited from class LocalAsyncLoadingCache

LocalAsyncLoadingCache.LoadingCacheView<K,V>

Nested classes/interfaces inherited from interface LocalAsyncCache

LocalAsyncCache.AbstractCacheView<K,V>, LocalAsyncCache.AsMapView<K,V>, LocalAsyncCache.AsyncAsMapView<K,V>, LocalAsyncCache.AsyncBulkCompleter<K,V>, LocalAsyncCache.CacheView<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final BoundedLocalCache<K, CompletableFuture<V>>	cache
(package private) final boolean	isWeighted
(package private) @Nullable ConcurrentMap<K, CompletableFuture<V>>	mapView
(package private) @Nullable Policy<K,V>	policy
private static final long	serialVersionUID

Fields inherited from class LocalAsyncLoadingCache

cacheView, canBulkLoad, loader, logger

Constructor Summary

Constructors

Constructor	Description
BoundedLocalAsyncLoadingCache(Caffeine<K,V> builder, AsyncCacheLoader<? super K, V> loader)

Method Summary

Modifier and Type	Method	Description
ConcurrentMap<K, CompletableFuture<V>>	asMap()	Returns a view of the entries stored in this cache as a thread-safe map.
BoundedLocalCache<K, CompletableFuture<V>>	cache()	Returns the backing LocalCache data store.
Policy<K,V>	policy()	Returns the policy supported by this implementation and its configuration.
private void	readObject(ObjectInputStream stream)
(package private) Object	writeReplace()

Methods inherited from class LocalAsyncLoadingCache

get, getAll, synchronous

Methods inherited from class Object

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

Methods inherited from interface LocalAsyncCache

composeResult, get, get, get, getAll, getAll, getIfPresent, handleCompletion, put

Field Details

serialVersionUID

private static final long serialVersionUID

See Also:

• Constant Field Values

cache

final BoundedLocalCache<K, CompletableFuture<V>> cache

isWeighted

final boolean isWeighted

mapView

@Nullable ConcurrentMap<K, CompletableFuture<V>> mapView

policy

@Nullable Policy<K,V> policy

Constructor Details

BoundedLocalAsyncLoadingCache

BoundedLocalAsyncLoadingCache(Caffeine<K,V> builder,
 AsyncCacheLoader<? super K, V> loader)

Method Details

cache

public BoundedLocalCache<K, CompletableFuture<V>> cache()

Description copied from interface: LocalAsyncCache

Returns the backing LocalCache data store.

Specified by:

cache in interface LocalAsyncCache<K,V>

asMap

public ConcurrentMap<K, CompletableFuture<V>> asMap()

Description copied from interface: AsyncCache

Returns a view of the entries stored in this cache as a thread-safe map. Modifications made to the map directly affect the cache.

A computation operation, such as ConcurrentMap.compute(K, BiFunction), performs the entire method invocation atomically, so the function is applied at most once per key. Some attempted update operations by other threads may be blocked while computation is in progress. The computation must not attempt to update any other mappings of this cache.

Iterators from the returned map are at least weakly consistent: they are safe for concurrent use, but if the cache is modified (including by eviction) after the iterator is created, it is undefined which of the changes (if any) will be reflected in that iterator.

Specified by:

asMap in interface AsyncCache<K,V>

Specified by:

asMap in interface AsyncLoadingCache<K,V>

Returns:

a thread-safe view of this cache supporting all of the optional Map operations

policy

public Policy<K,V> policy()

Description copied from interface: LocalAsyncCache

Returns the policy supported by this implementation and its configuration.

Specified by:

policy in interface LocalAsyncCache<K,V>

readObject

private void readObject(ObjectInputStream stream)
                 throws InvalidObjectException

Throws:

InvalidObjectException

writeReplace

Object writeReplace()