net.imglib2.cache.ref

Class WeakRefVolatileLoaderCache<K,V>

java.lang.Object

net.imglib2.cache.ref.WeakRefVolatileLoaderCache<K,V>

All Implemented Interfaces:

Invalidate<K>, AbstractVolatileCache<K,V>, VolatileLoaderCache<K,V>

public class WeakRefVolatileLoaderCache<K,V>
extends Object
implements VolatileLoaderCache<K,V>

Field Summary

Fields inherited from interface net.imglib2.cache.Invalidate

defaultParallelismThreshold

Constructor Summary

Constructors

Constructor and Description
WeakRefVolatileLoaderCache(LoaderCache<K,V> backingCache, BlockingFetchQueues<Callable<?>> fetchQueue)

Method Summary

Modifier and Type	Method and Description
void	cleanUp() Remove entries from the cache whose references have been garbage-collected.
V	get(K key, VolatileCacheLoader<? super K,? extends V> loader, CacheHints hints)
V	getIfPresent(Object key, CacheHints hints)
void	invalidate(K key) Removes and discards the entry with the specified key.
void	invalidateAll(long parallelismThreshold) Removes and discards all entries.
void	invalidateIf(long parallelismThreshold, Predicate<K> condition) Removes and discards all entries with keys matching condition.

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.imglib2.cache.volatiles.VolatileLoaderCache

withLoader

Methods inherited from interface net.imglib2.cache.Invalidate

invalidateAll, invalidateIf

Constructor Detail

WeakRefVolatileLoaderCache

public WeakRefVolatileLoaderCache(LoaderCache<K,V> backingCache,
                                  BlockingFetchQueues<Callable<?>> fetchQueue)

Method Detail

getIfPresent

public V getIfPresent(Object key,
                      CacheHints hints)
               throws ExecutionException

Specified by:

getIfPresent in interface AbstractVolatileCache<K,V>

Throws:

ExecutionException

get

public V get(K key,
             VolatileCacheLoader<? super K,? extends V> loader,
             CacheHints hints)
      throws ExecutionException

Specified by:

get in interface VolatileLoaderCache<K,V>

Throws:

ExecutionException

cleanUp

public void cleanUp()

Remove entries from the cache whose references have been garbage-collected.

invalidate

public void invalidate(K key)

Description copied from interface: AbstractVolatileCache

Removes and discards the entry with the specified key. Calls CacheRemover.invalidate(Object) for the discarded entry, (which should in turn remove it from any backing cache)

Note that this will not call CacheRemover.onRemoval(Object, Object) for the discarded entry.

There must be no concurrent get() operations for key. This may result in cache corruption and/or a deadlock.

Specified by:

invalidate in interface Invalidate<K>

Specified by:

invalidate in interface AbstractVolatileCache<K,V>

Parameters:

key - key of the entry to remove

invalidateIf

public void invalidateIf(long parallelismThreshold,
                         Predicate<K> condition)

Description copied from interface: AbstractVolatileCache

Removes and discards all entries with keys matching condition. Calls Invalidate.invalidateIf(Predicate) for the discarded entries, (which should in turn remove them from any backing cache)

Note that this will not call CacheRemover.onRemoval(Object, Object) for the discarded entries.

There must be no concurrent get() operations for keys matching condition. This may result in cache corruption and/or a deadlock.

Specified by:

invalidateIf in interface Invalidate<K>

Specified by:

invalidateIf in interface AbstractVolatileCache<K,V>

Parameters:

parallelismThreshold - the (estimated) number of entries in the cache needed for this operation to be executed in parallel

condition - condition on keys of entries to remove

invalidateAll

public void invalidateAll(long parallelismThreshold)

Description copied from interface: AbstractVolatileCache

Removes and discards all entries. Calls Invalidate.invalidateAll() (which should in turn invalidate any backing cache)

Note that this will not call CacheRemover.onRemoval(Object, Object) for the discarded entries.

There must be no concurrent get() operations. This may result in cache corruption and/or a deadlock.

Specified by:

invalidateAll in interface Invalidate<K>

Specified by:

invalidateAll in interface AbstractVolatileCache<K,V>

Parameters:

parallelismThreshold - the (estimated) number of entries in the cache needed for this operation to be executed in parallel