Class UnboundedLocalCache.UnboundedLocalAsyncCache<K,V>

java.lang.Object

com.github.benmanes.caffeine.cache.UnboundedLocalCache.UnboundedLocalAsyncCache<K,V>

All Implemented Interfaces:

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

Enclosing class:

UnboundedLocalCache<K,V>

static final class UnboundedLocalCache.UnboundedLocalAsyncCache<K,V>
extends Object
implements LocalAsyncCache<K,V>, Serializable

Nested Class Summary

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 UnboundedLocalCache<K, CompletableFuture<V>>	cache
(package private) @Nullable LocalAsyncCache.CacheView<K,V>	cacheView
(package private) @Nullable ConcurrentMap<K, CompletableFuture<V>>	mapView
(package private) @Nullable Policy<K,V>	policy
private static final long	serialVersionUID

Fields inherited from interface LocalAsyncCache

logger

Constructor Summary

Constructors

Constructor	Description
UnboundedLocalAsyncCache(Caffeine<K,V> builder)

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.
UnboundedLocalCache<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)
Cache<K,V>	synchronous()	Returns a view of the entries stored in this cache as a synchronous Cache.
(package private) Object	writeReplace()

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 UnboundedLocalCache<K, CompletableFuture<V>> cache

mapView

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

cacheView

@Nullable LocalAsyncCache.CacheView<K,V> cacheView

policy

@Nullable Policy<K,V> policy

Constructor Details

UnboundedLocalAsyncCache

UnboundedLocalAsyncCache(Caffeine<K,V> builder)

Method Details

cache

public UnboundedLocalCache<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>

Returns:

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

synchronous

public Cache<K,V> synchronous()

Description copied from interface: AsyncCache

Returns a view of the entries stored in this cache as a synchronous Cache. A mapping is not present if the value is currently being loaded. Modifications made to the synchronous cache directly affect the asynchronous cache. If a modification is made to a mapping that is currently loading, the operation blocks until the computation completes.

Specified by:

synchronous in interface AsyncCache<K,V>

Returns:

a thread-safe synchronous view of this cache

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()