Caffeine cache 3.1.8 · com.github.benmanes.caffeine.cache.AsyncCacheLoader

Method Summary

Modifier and Type	Method and Description
public CompletableFuture<? extends V>	Returns: the future value associated with `key` asyncLoad(K the non-null key whose value should be loaded key, Executor the executor with which the entry may be asynchronously loaded with executor) Asynchronously computes or retrieves the value corresponding to `key`.
public default CompletableFuture<? extends Map<? extends K, ? extends V>>	Returns: a future containing the map from each key in `keys` to the value associated with that key; may not contain null values asyncLoadAll(Set<? extends K> the unique, non-null keys whose values should be loaded keys, Executor the executor with which the entry may be asynchronously loaded with executor) Asynchronously computes or retrieves the values corresponding to `keys`.
public default CompletableFuture<? extends V>	Returns: a future containing the new value associated with `key`, or containing `null` if the mapping is to be removed asyncReload(K the non-null key whose value should be loaded key, V the non-null old value corresponding to `key` oldValue, Executor the executor with which the entry may be asynchronously loaded with executor) Asynchronously computes or retrieves a replacement value corresponding to an already-cached `key`.
public static < the key type K, the value type V> AsyncCacheLoader<K, V>	Returns: an asynchronous cache loader that delegates to the supplied `mappingFunction` bulk(Function<? super Set<? extends K>, ? extends Map<? extends K, ? extends V>> the function to asynchronously compute the values mappingFunction) Returns an asynchronous cache loader that delegates to the supplied mapping function for retrieving the values.
public static < the key type K, the value type V> AsyncCacheLoader<K, V>	Returns: an asynchronous cache loader that delegates to the supplied `mappingFunction` bulk(BiFunction<? super Set<? extends K>, ? super Executor, ? extends CompletableFuture<? extends Map<? extends K, ? extends V>>> the function to asynchronously compute the values mappingFunction) Returns an asynchronous cache loader that delegates to the supplied mapping function for retrieving the values.

Method Detail

asyncLoad back to summary

asyncLoad	back to summary
public CompletableFuture<? extends V> asyncLoad(K key, Executor executor) throws Exception Asynchronously computes or retrieves the value corresponding to `key`. Warning loading must not attempt to update any mappings of this cache directly. Parameters key:K the non-null key whose value should be loaded executor:Executor the executor with which the entry may be asynchronously loaded with Returns:CompletableFuture<? extends V> the future value associated with `key` Exceptions Exception: or Error, in which case the mapping is unchanged InterruptedException: if this method is interrupted. `InterruptedException` is treated like any other `Exception` in all respects except that, when it is caught, the thread's interrupt status is set

public CompletableFuture<? extends V> asyncLoad(K key, Executor executor) throws Exception

Asynchronously computes or retrieves the value corresponding to key.

Warning

loading must not attempt to update any mappings of this cache directly.

Parameters

key:K: the non-null key whose value should be loaded
executor:Executor: the executor with which the entry may be asynchronously loaded with

Returns:CompletableFuture<? extends V>

the future value associated with key

Exceptions

Exception:: or Error, in which case the mapping is unchanged
InterruptedException:: if this method is interrupted. InterruptedException is treated like any other Exception in all respects except that, when it is caught, the thread's interrupt status is set

asyncLoadAll back to summary

asyncLoadAll	back to summary
public default CompletableFuture<? extends Map<? extends K, ? extends V>> asyncLoadAll(Set<? extends K> keys, Executor executor) throws Exception Asynchronously computes or retrieves the values corresponding to `keys`. This method is called by `AsyncLoadingCache#getAll`. If the returned map doesn't contain all requested `keys`, then the entries it does contain will be cached, and `getAll` will return the partial results. If the returned map contains extra keys not present in `keys`, then all returned entries will be cached, but only the entries for `keys` will be returned from `getAll`. This method should be overridden when bulk retrieval is significantly more efficient than many individual lookups. Note that `AsyncLoadingCache#getAll` will defer to individual calls to `AsyncLoadingCache#get` if this method is not overridden. Warning loading must not attempt to update any mappings of this cache directly. Parameters keys:Set<? extends K> the unique, non-null keys whose values should be loaded executor:Executor the executor with which the entry may be asynchronously loaded with Returns:CompletableFuture<? extends Map<? extends K, ? extends V>> a future containing the map from each key in `keys` to the value associated with that key; may not contain null values Exceptions Exception: or Error, in which case the mappings are unchanged InterruptedException: if this method is interrupted. `InterruptedException` is treated like any other `Exception` in all respects except that, when it is caught, the thread's interrupt status is set

public default CompletableFuture<? extends Map<? extends K, ? extends V>> asyncLoadAll(Set<? extends K> keys, Executor executor) throws Exception

Asynchronously computes or retrieves the values corresponding to keys. This method is called by AsyncLoadingCache#getAll.

If the returned map doesn't contain all requested keys, then the entries it does contain will be cached, and getAll will return the partial results. If the returned map contains extra keys not present in keys, then all returned entries will be cached, but only the entries for keys will be returned from getAll.

This method should be overridden when bulk retrieval is significantly more efficient than many individual lookups. Note that AsyncLoadingCache#getAll will defer to individual calls to AsyncLoadingCache#get if this method is not overridden.

Warning

loading must not attempt to update any mappings of this cache directly.

Parameters

keys:Set<? extends K>: the unique, non-null keys whose values should be loaded
executor:Executor: the executor with which the entry may be asynchronously loaded with

Returns:CompletableFuture<? extends Map<? extends K, ? extends V>>

a future containing the map from each key in keys to the value associated with that key; may not contain null values

Exceptions

Exception:: or Error, in which case the mappings are unchanged
InterruptedException:: if this method is interrupted. InterruptedException is treated like any other Exception in all respects except that, when it is caught, the thread's interrupt status is set

asyncReload back to summary

asyncReload	back to summary
public default CompletableFuture<? extends V> asyncReload(K key, V oldValue, Executor executor) throws Exception Asynchronously computes or retrieves a replacement value corresponding to an already-cached `key`. If the replacement value is not found, then the mapping will be removed if `null` is computed. This method is called when an existing cache entry is refreshed by `Caffeine#refreshAfterWrite`, or through a call to `LoadingCache#refresh`. Warning loading must not attempt to update any mappings of this cache directly or block waiting for other cache operations to complete. Note all exceptions thrown by this method will be logged and then swallowed. Parameters key:K the non-null key whose value should be loaded oldValue:V the non-null old value corresponding to `key` executor:Executor the executor with which the entry may be asynchronously loaded with Returns:CompletableFuture<? extends V> a future containing the new value associated with `key`, or containing `null` if the mapping is to be removed Exceptions Exception: or Error, in which case the mapping is unchanged InterruptedException: if this method is interrupted. `InterruptedException` is treated like any other `Exception` in all respects except that, when it is caught, the thread's interrupt status is set

public default CompletableFuture<? extends V> asyncReload(K key, V oldValue, Executor executor) throws Exception

Asynchronously computes or retrieves a replacement value corresponding to an already-cached key. If the replacement value is not found, then the mapping will be removed if null is computed. This method is called when an existing cache entry is refreshed by Caffeine#refreshAfterWrite, or through a call to LoadingCache#refresh.

Warning

loading must not attempt to update any mappings of this cache directly or block waiting for other cache operations to complete.

Note

all exceptions thrown by this method will be logged and then swallowed.

Parameters

key:K: the non-null key whose value should be loaded
oldValue:V: the non-null old value corresponding to key
executor:Executor: the executor with which the entry may be asynchronously loaded with

Returns:CompletableFuture<? extends V>

a future containing the new value associated with key, or containing null if the mapping is to be removed

Exceptions

Exception:: or Error, in which case the mapping is unchanged
InterruptedException:: if this method is interrupted. InterruptedException is treated like any other Exception in all respects except that, when it is caught, the thread's interrupt status is set

bulk back to summary

bulk	back to summary
public static <K, V> AsyncCacheLoader<K, V> bulk(Function<? super Set<? extends K>, ? extends Map<? extends K, ? extends V>> mappingFunction) Returns an asynchronous cache loader that delegates to the supplied mapping function for retrieving the values. Note that `asyncLoad` will discard any additional mappings loaded when retrieving the `key` prior to returning to the value to the cache. Usage example: `AsyncCacheLoader<Key, Graph> loader = AsyncCacheLoader.bulk( keys -> createExpensiveGraphs(keys)); AsyncLoadingCache<Key, Graph> cache = Caffeine.newBuilder().buildAsync(loader);` Parameters <K> the key type <V> the value type mappingFunction:Function<? super Set<? extends K>, ? extends Map<? extends K, ? extends V>> the function to asynchronously compute the values Returns:AsyncCacheLoader<K, V> an asynchronous cache loader that delegates to the supplied `mappingFunction` Exceptions NullPointerException: if the mappingFunction is null

public static <K, V> AsyncCacheLoader<K, V> bulk(Function<? super Set<? extends K>, ? extends Map<? extends K, ? extends V>> mappingFunction)

Returns an asynchronous cache loader that delegates to the supplied mapping function for retrieving the values. Note that asyncLoad will discard any additional mappings loaded when retrieving the key prior to returning to the value to the cache.

Usage example:

AsyncCacheLoader<Key, Graph> loader = AsyncCacheLoader.bulk(
      keys -> createExpensiveGraphs(keys));
  AsyncLoadingCache<Key, Graph> cache = Caffeine.newBuilder().buildAsync(loader);

Parameters

<K>: the key type
<V>: the value type
mappingFunction:Function<? super Set<? extends K>, ? extends Map<? extends K, ? extends V>>: the function to asynchronously compute the values

Returns:AsyncCacheLoader<K, V>

an asynchronous cache loader that delegates to the supplied mappingFunction

Exceptions

NullPointerException:: if the mappingFunction is null

bulk back to summary

bulk	back to summary
public static <K, V> AsyncCacheLoader<K, V> bulk(BiFunction<? super Set<? extends K>, ? super Executor, ? extends CompletableFuture<? extends Map<? extends K, ? extends V>>> mappingFunction) Returns an asynchronous cache loader that delegates to the supplied mapping function for retrieving the values. Note that `asyncLoad` will silently discard any additional mappings loaded when retrieving the `key` prior to returning to the value to the cache. Usage example: `AsyncCacheLoader<Key, Graph> loader = AsyncCacheLoader.bulk( (keys, executor) -> createExpensiveGraphs(keys, executor)); AsyncLoadingCache<Key, Graph> cache = Caffeine.newBuilder().buildAsync(loader);` Parameters <K> the key type <V> the value type mappingFunction:BiFunction<? super Set<? extends K>, ? super Executor, ? extends CompletableFuture<? extends Map<? extends K, ? extends V>>> the function to asynchronously compute the values Returns:AsyncCacheLoader<K, V> an asynchronous cache loader that delegates to the supplied `mappingFunction` Exceptions NullPointerException: if the mappingFunction is null

public static <K, V> AsyncCacheLoader<K, V> bulk(BiFunction<? super Set<? extends K>, ? super Executor, ? extends CompletableFuture<? extends Map<? extends K, ? extends V>>> mappingFunction)

Returns an asynchronous cache loader that delegates to the supplied mapping function for retrieving the values. Note that asyncLoad will silently discard any additional mappings loaded when retrieving the key prior to returning to the value to the cache.

Usage example:

AsyncCacheLoader<Key, Graph> loader = AsyncCacheLoader.bulk(
      (keys, executor) -> createExpensiveGraphs(keys, executor));
  AsyncLoadingCache<Key, Graph> cache = Caffeine.newBuilder().buildAsync(loader);

Parameters

<K>: the key type
<V>: the value type
mappingFunction:BiFunction<? super Set<? extends K>, ? super Executor, ? extends CompletableFuture<? extends Map<? extends K, ? extends V>>>: the function to asynchronously compute the values

Returns:AsyncCacheLoader<K, V>

an asynchronous cache loader that delegates to the supplied mappingFunction

Exceptions

NullPointerException:: if the mappingFunction is null

public Interface AsyncCacheLoader<K, V>

Method Summary

Method Detail