Package com.atlassian.bamboo.utils.collections

Class AlwaysInvalidatingCacheDecorator<K,V>

java.lang.Object

com.atlassian.bamboo.utils.collections.AlwaysInvalidatingCacheDecorator<K,V>

All Implemented Interfaces:

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

Direct Known Subclasses:

AlwaysInvalidatingCacheDecorator

public class AlwaysInvalidatingCacheDecorator<K,V>
extends Object
implements com.google.common.cache.LoadingCache<K,V>

This decorator ensures that when invalidate() is called while CacheLoader.load() is being executed, the loaded value will be invalidated. Both get() and invalidate() share the same exclusive reentrant lock, thus making it safe to call invalidate from within load() method. If invalidate() is called during get(), get() will be retried. This will happen only once, a subsequent attempt to invalidate during get() will result in a IllegalStateException. Note: invalidateAll() cannot be called from get().

Constructor Summary

Constructors

Constructor	Description
AlwaysInvalidatingCacheDecorator(com.google.common.cache.LoadingCache<K,V> cache)

Method Summary

Modifier and Type	Method	Description
V	apply(K key)
ConcurrentMap<K,V>	asMap()
void	cleanUp()
V	get(K key)
V	get(K k, @NotNull Callable<? extends V> callable)
com.google.common.collect.ImmutableMap<K,V>	getAll(Iterable<? extends K> keys)
com.google.common.collect.ImmutableMap<K,V>	getAllPresent(@NotNull Iterable<?> keys)
V	getIfPresent(Object key)
V	getUnchecked(K key)
void	invalidate(@NotNull Object key)
void	invalidateAll()
void	invalidateAll(@NotNull Iterable<?> objects)
void	put(K k, V v)
void	putAll(Map<? extends K,? extends V> m)
void	refresh(K key)
long	size()
com.google.common.cache.CacheStats	stats()
static <K,V> com.google.common.cache.LoadingCache<K,V>	wrap(com.google.common.cache.LoadingCache<K,V> cache)

Methods inherited from class java.lang.Object

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

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

equals

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Detail

AlwaysInvalidatingCacheDecorator

public AlwaysInvalidatingCacheDecorator(com.google.common.cache.LoadingCache<K,V> cache)

Method Detail

get

public V get(@NotNull
             K key)
      throws ExecutionException

Specified by:

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

Throws:

ExecutionException

getAll

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

Specified by:

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

Throws:

ExecutionException

refresh

public void refresh(K key)

Specified by:

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

putAll

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

Specified by:

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

getIfPresent

@Nullable
public V getIfPresent(Object key)

Specified by:

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

get

public V get(@NotNull
             K k,
             @NotNull
             @NotNull Callable<? extends V> callable)
      throws ExecutionException

Specified by:

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

Throws:

ExecutionException

getAllPresent

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

Specified by:

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

getUnchecked

public V getUnchecked(@NotNull
                      K key)

Specified by:

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

apply

public V apply(@NotNull
               K key)

Specified by:

apply in interface com.google.common.base.Function<K,V>

Specified by:

apply in interface Function<K,V>

Specified by:

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

invalidate

public void invalidate(@NotNull
                       @NotNull Object key)

Specified by:

invalidate 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>

invalidateAll

public void invalidateAll(@NotNull
                          @NotNull Iterable<?> objects)

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>

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>

cleanUp

public void cleanUp()

Specified by:

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

put

public void put(@NotNull
                K k,
                @NotNull
                V v)

Specified by:

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

wrap

public static <K,V> com.google.common.cache.LoadingCache<K,V> wrap(com.google.common.cache.LoadingCache<K,V> cache)