org.spf4j.concurrent

Class UnboundedLoadingCache2<K,V>

java.lang.Object

org.spf4j.concurrent.UnboundedLoadingCache2<K,V>

All Implemented Interfaces:

com.google.common.cache.Cache<K,V>, com.google.common.cache.LoadingCache<K,V>, Function<K,V>

@ParametersAreNonnullByDefault
public final class UnboundedLoadingCache2<K,V>
extends Object
implements com.google.common.cache.LoadingCache<K,V>

Simple adapter that adapts a java ConcurrentMap to a guava cache. See UnboundedLoadingCache for rationale and benchmark data to see why this is not the default implementation.

Author:

zoly

Constructor Summary

Constructors

Constructor and Description
UnboundedLoadingCache2(int initialSize, com.google.common.cache.CacheLoader<K,V> loader)
UnboundedLoadingCache2(int initialSize, int concurrency, com.google.common.cache.CacheLoader<K,V> loader)

Method Summary

Modifier and Type	Method and Description
V	apply(K key)
ConcurrentMap<K,V>	asMap()
void	cleanUp()
V	get(K key)
V	get(K key, Callable<? extends V> valueLoader)
com.google.common.collect.ImmutableMap<K,V>	getAll(Iterable<? extends K> keys)
com.google.common.collect.ImmutableMap<K,V>	getAllPresent(Iterable<?> keys)
V	getIfPresent(Object key)
V	getUnchecked(K key)
void	invalidate(Object key)
void	invalidateAll()
void	invalidateAll(Iterable<?> keys)
void	put(K key, V value)
void	putAll(Map<? extends K,? extends V> m)
void	refresh(K key)
long	size()
com.google.common.cache.CacheStats	stats()
String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.google.common.base.Function

equals

Methods inherited from interface java.util.function.Function

andThen, compose, identity

Constructor Detail

UnboundedLoadingCache2

public UnboundedLoadingCache2(int initialSize,
                              com.google.common.cache.CacheLoader<K,V> loader)

UnboundedLoadingCache2

public UnboundedLoadingCache2(int initialSize,
                              int concurrency,
                              com.google.common.cache.CacheLoader<K,V> loader)

Method Detail

get

public V get(K key)

Specified by:

get in interface com.google.common.cache.LoadingCache<K,V>

getUnchecked

public V getUnchecked(K key)

Specified by:

getUnchecked in interface com.google.common.cache.LoadingCache<K,V>

getAll

public com.google.common.collect.ImmutableMap<K,V> getAll(Iterable<? extends K> keys)

Specified by:

getAll in interface com.google.common.cache.LoadingCache<K,V>

apply

public V apply(K key)

Specified by:

apply in interface com.google.common.cache.LoadingCache<K,V>

Specified by:

apply in interface Function<K,V>

refresh

public void refresh(K key)

Specified by:

refresh in interface com.google.common.cache.LoadingCache<K,V>

asMap

public ConcurrentMap<K,V> asMap()

Specified by:

asMap in interface com.google.common.cache.Cache<K,V>

Specified by:

asMap in interface com.google.common.cache.LoadingCache<K,V>

getIfPresent

public V getIfPresent(Object key)

Specified by:

getIfPresent in interface com.google.common.cache.Cache<K,V>

get

public V get(K key,
             Callable<? extends V> valueLoader)

Specified by:

get in interface com.google.common.cache.Cache<K,V>

getAllPresent

public com.google.common.collect.ImmutableMap<K,V> getAllPresent(Iterable<?> keys)

Specified by:

getAllPresent in interface com.google.common.cache.Cache<K,V>

put

public void put(K key,
                V value)

Specified by:

put in interface com.google.common.cache.Cache<K,V>

putAll

public void putAll(Map<? extends K,? extends V> m)

Specified by:

putAll in interface com.google.common.cache.Cache<K,V>

invalidate

public void invalidate(Object key)

Specified by:

invalidate in interface com.google.common.cache.Cache<K,V>

invalidateAll

public void invalidateAll(Iterable<?> keys)

Specified by:

invalidateAll in interface com.google.common.cache.Cache<K,V>

invalidateAll

public void invalidateAll()

Specified by:

invalidateAll in interface com.google.common.cache.Cache<K,V>

size

public long size()

Specified by:

size in interface com.google.common.cache.Cache<K,V>

stats

public com.google.common.cache.CacheStats stats()

Specified by:

stats in interface com.google.common.cache.Cache<K,V>

cleanUp

public void cleanUp()

Specified by:

cleanUp in interface com.google.common.cache.Cache<K,V>

toString

public String toString()

Overrides:

toString in class Object