Package com.github.benmanes.caffeine.jcache.integration

Class JCacheLoaderAdapter<K,V>

java.lang.Object

com.github.benmanes.caffeine.jcache.integration.JCacheLoaderAdapter<K,V>

All Implemented Interfaces:

AsyncCacheLoader<K,Expirable<V>>, CacheLoader<K,Expirable<V>>

public final class JCacheLoaderAdapter<K,V>
extends java.lang.Object
implements CacheLoader<K,Expirable<V>>

An adapter from a JCache cache loader to Caffeine's.

Field Summary

Fields

Modifier and Type	Field	Description
private CacheProxy<K,V>	cache
private javax.cache.integration.CacheLoader<K,V>	delegate
private EventDispatcher<K,V>	dispatcher
private javax.cache.expiry.ExpiryPolicy	expiry
private JCacheStatisticsMXBean	statistics
private Ticker	ticker

Constructor Summary

Constructors

Constructor	Description
JCacheLoaderAdapter(javax.cache.integration.CacheLoader<K,V> delegate, EventDispatcher<K,V> dispatcher, javax.cache.expiry.ExpiryPolicy expiry, Ticker ticker, JCacheStatisticsMXBean statistics)

Method Summary

Modifier and Type	Method	Description
private long	expireTimeMS()
@Nullable Expirable<V>	load(K key)	Computes or retrieves the value corresponding to key.
java.util.Map<K,Expirable<V>>	loadAll(java.lang.Iterable<? extends K> keys)	Computes or retrieves the values corresponding to keys.
void	setCache(CacheProxy<K,V> cache)	Sets the cache instance that was created with this loader.

Methods inherited from class java.lang.Object

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

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

asyncLoad, asyncLoadAll, asyncReload, reload

Field Detail

statistics

private final JCacheStatisticsMXBean statistics

dispatcher

private final EventDispatcher<K,V> dispatcher

delegate

private final javax.cache.integration.CacheLoader<K,V> delegate

expiry

private final javax.cache.expiry.ExpiryPolicy expiry

ticker

private final Ticker ticker

cache

private CacheProxy<K,V> cache

Constructor Detail

JCacheLoaderAdapter

public JCacheLoaderAdapter(javax.cache.integration.CacheLoader<K,V> delegate,
                           EventDispatcher<K,V> dispatcher,
                           javax.cache.expiry.ExpiryPolicy expiry,
                           Ticker ticker,
                           JCacheStatisticsMXBean statistics)

Method Detail

setCache

public void setCache(CacheProxy<K,V> cache)

Sets the cache instance that was created with this loader.

Parameters:

cache - the cache that uses this loader

load

public @Nullable Expirable<V> load(K key)

Description copied from interface: CacheLoader

Computes or retrieves the value corresponding to key.

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

Specified by:

load in interface CacheLoader<K,V>

Parameters:

key - the non-null key whose value should be loaded

Returns:

the value associated with key or null if not found

loadAll

public java.util.Map<K,Expirable<V>> loadAll(java.lang.Iterable<? extends K> keys)

Description copied from interface: CacheLoader

Computes or retrieves the values corresponding to keys. This method is called by LoadingCache.getAll(java.lang.Iterable<? extends K>).

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 LoadingCache.getAll(java.lang.Iterable<? extends K>) will defer to individual calls to LoadingCache.get(K) if this method is not overridden.

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

Specified by:

loadAll in interface CacheLoader<K,V>

Parameters:

keys - the unique, non-null keys whose values should be loaded

Returns:

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

expireTimeMS

private long expireTimeMS()