Package org.jgroups.blocks

Class Cache<K,V>

java.lang.Object

org.jgroups.blocks.Cache<K,V>

public class Cache<K,V>
extends Object

Simple cache which maintains keys and value. A reaper can be enabled which periodically evicts expired entries. Also, when the cache is configured to be bounded, entries in excess of the max size will be evicted on put().

Author:

Bela Ban

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	Cache.ChangeListener
static class	Cache.Value<V>

Constructor Summary

Constructors

Constructor	Description
Cache()

Method Summary

Modifier and Type	Method	Description
void	addChangeListener(Cache.ChangeListener l)
void	disableReaping()
String	dump()
void	enableReaping(long interval)	Runs the reaper every interval ms, evicts expired items
Set<Map.Entry<K,Cache.Value<V>>>	entrySet()
V	get(K key)
Cache.Value<V>	getEntry(K key)
ConcurrentMap<K,Cache.Value<V>>	getInternalMap()	This method should not be used to add or remove elements ! It was just added because ReplCacheDemo requires it for its data model
int	getMaxNumberOfEntries()
int	getSize()
boolean	isReapingEnabled()
V	put(K key, V val, long caching_time)
V	remove(K key)
void	removeChangeListener(Cache.ChangeListener l)
void	setMaxNumberOfEntries(int max_num_entries)
void	start()
void	stop()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Details

Cache

public Cache()

Method Details

getMaxNumberOfEntries

public int getMaxNumberOfEntries()

setMaxNumberOfEntries

public void setMaxNumberOfEntries(int max_num_entries)

addChangeListener

public void addChangeListener(Cache.ChangeListener l)

removeChangeListener

public void removeChangeListener(Cache.ChangeListener l)

getSize

public int getSize()

isReapingEnabled

public boolean isReapingEnabled()

enableReaping

public void enableReaping(long interval)

Runs the reaper every interval ms, evicts expired items

disableReaping

public void disableReaping()

start

public void start()

stop

public void stop()

put

public V put(K key,
 V val,
 long caching_time)

Parameters:

key -

val -

caching_time - Number of milliseconds to keep an entry in the cache. -1 means don't cache (if reaping is enabled, we'll evict an entry with -1 caching time), 0 means never evict. In the latter case, we can still evict an entry with 0 caching time: when we have a bounded cache, we evict in order of insertion no matter what the caching time is.

get

public V get(K key)

getInternalMap

public ConcurrentMap<K,Cache.Value<V>> getInternalMap()

This method should not be used to add or remove elements ! It was just added because ReplCacheDemo requires it for its data model

Returns:

getEntry

public Cache.Value<V> getEntry(K key)

remove

public V remove(K key)

entrySet

public Set<Map.Entry<K,Cache.Value<V>>> entrySet()

toString

public String toString()

Overrides:

toString in class Object

dump

public String dump()