Class LocalAsyncCache.AsyncBulkCompleter<K,V>

java.lang.Object

com.github.benmanes.caffeine.cache.LocalAsyncCache.AsyncBulkCompleter<K,V>

All Implemented Interfaces:

BiConsumer<Map<K,V>, Throwable>

Enclosing interface:

LocalAsyncCache<K,V>

public static final class LocalAsyncCache.AsyncBulkCompleter<K,V>
extends Object
implements BiConsumer<Map<K,V>, Throwable>

A function executed asynchronously after a bulk load completes.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static final class	LocalAsyncCache.AsyncBulkCompleter.NullMapCompletionException

Field Summary

Fields

Modifier and Type	Field	Description
private final LocalCache<K, CompletableFuture<V>>	cache
private final Map<K, CompletableFuture<V>>	proxies
private final long	startTime

Constructor Summary

Constructors

Constructor	Description
AsyncBulkCompleter(LocalCache<K, CompletableFuture<V>> cache, Map<K, CompletableFuture<V>> proxies)

Method Summary

Modifier and Type	Method	Description
void	accept(@Nullable Map<K,V> result, @Nullable Throwable error)
private void	addNewEntries(Map<K,V> result)	Adds to the cache any extra entries computed that were not requested.
private void	fillProxies(Map<K,V> result)	Populates the proxies with the computed result.

Methods inherited from class Object

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

Methods inherited from interface BiConsumer

andThen

Field Details

cache

private final LocalCache<K, CompletableFuture<V>> cache

proxies

private final Map<K, CompletableFuture<V>> proxies

startTime

private final long startTime

Constructor Details

AsyncBulkCompleter

AsyncBulkCompleter(LocalCache<K, CompletableFuture<V>> cache,
 Map<K, CompletableFuture<V>> proxies)

Method Details

accept

public void accept(@Nullable Map<K,V> result,
 @Nullable Throwable error)

Specified by:

accept in interface BiConsumer<K,V>

fillProxies

private void fillProxies(Map<K,V> result)

Populates the proxies with the computed result.

addNewEntries

private void addNewEntries(Map<K,V> result)

Adds to the cache any extra entries computed that were not requested.