org.infinispan.container

Class DefaultDataContainer

java.lang.Object

org.infinispan.container.DefaultDataContainer

All Implemented Interfaces:

Iterable<InternalCacheEntry>, DataContainer

@ThreadSafe
public class DefaultDataContainer
extends Object
implements DataContainer

DefaultDataContainer is both eviction and non-eviction based data container.

Since:

4.0

Author:

Manik Surtani, Galder Zamarreño, Vladimir Blagojevic, Trustin Lee

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultDataContainer.EntryIterator

Field Summary

Fields

Modifier and Type	Field and Description
protected ConcurrentMap<Object,InternalCacheEntry>	entries
protected InternalEntryFactory	entryFactory
protected org.infinispan.container.DefaultDataContainer.DefaultEvictionListener	evictionListener

Constructor Summary

Constructors

Modifier	Constructor and Description
	DefaultDataContainer(int concurrencyLevel)
	DefaultDataContainer(int concurrencyLevel, Equivalence keyEq, Equivalence valueEq)
protected	DefaultDataContainer(int concurrencyLevel, int maxEntries, EvictionStrategy strategy, EvictionThreadPolicy policy, Equivalence keyEquivalence, Equivalence valueEquivalence)

Method Summary

Methods

Modifier and Type	Method and Description
static DataContainer	boundedDataContainer(int concurrencyLevel, int maxEntries, EvictionStrategy strategy, EvictionThreadPolicy policy, Equivalence keyEquivalence, Equivalence valueEquivalence)
void	clear() Removes all entries in the container
boolean	containsKey(Object k) Tests whether an entry exists in the container
Set<InternalCacheEntry>	entrySet() Returns a mutable set of immutable cache entries exposed as immutable Map.Entry instances.
InternalCacheEntry	get(Object k) Retrieves a cached entry
void	initialize(EvictionManager evictionManager, PassivationManager passivator, InternalEntryFactory entryFactory, ActivationManager activator, PersistenceManager clm, TimeService timeService)
Iterator<InternalCacheEntry>	iterator()
Set<Object>	keySet() Returns a set of keys in the container.
InternalCacheEntry	peek(Object key) Retrieves a cache entry in the same way as DataContainer.get(Object)} except that it does not update or reorder any of the internal constructs.
void	purgeExpired() Purges entries that have passed their expiry time
void	put(Object k, Object v, Metadata metadata) Puts an entry in the cache along with metadata adding information such lifespan of entry, max idle time, version information...etc.
InternalCacheEntry	remove(Object k) Removes an entry from the cache
int	size()
static DataContainer	unBoundedDataContainer(int concurrencyLevel)
static DataContainer	unBoundedDataContainer(int concurrencyLevel, Equivalence keyEquivalence, Equivalence valueEquivalence)
Collection<Object>	values()

Methods inherited from class java.lang.Object

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

Field Detail

entries

protected final ConcurrentMap<Object,InternalCacheEntry> entries

entryFactory

protected InternalEntryFactory entryFactory

evictionListener

protected final org.infinispan.container.DefaultDataContainer.DefaultEvictionListener evictionListener

Constructor Detail

DefaultDataContainer

public DefaultDataContainer(int concurrencyLevel)

DefaultDataContainer

public DefaultDataContainer(int concurrencyLevel,
                    Equivalence keyEq,
                    Equivalence valueEq)

DefaultDataContainer

protected DefaultDataContainer(int concurrencyLevel,
                    int maxEntries,
                    EvictionStrategy strategy,
                    EvictionThreadPolicy policy,
                    Equivalence keyEquivalence,
                    Equivalence valueEquivalence)

Method Detail

initialize

public void initialize(EvictionManager evictionManager,
              PassivationManager passivator,
              InternalEntryFactory entryFactory,
              ActivationManager activator,
              PersistenceManager clm,
              TimeService timeService)

boundedDataContainer

public static DataContainer boundedDataContainer(int concurrencyLevel,
                                 int maxEntries,
                                 EvictionStrategy strategy,
                                 EvictionThreadPolicy policy,
                                 Equivalence keyEquivalence,
                                 Equivalence valueEquivalence)

unBoundedDataContainer

public static DataContainer unBoundedDataContainer(int concurrencyLevel,
                                   Equivalence keyEquivalence,
                                   Equivalence valueEquivalence)

unBoundedDataContainer

public static DataContainer unBoundedDataContainer(int concurrencyLevel)

peek

public InternalCacheEntry peek(Object key)

Description copied from interface: DataContainer

Retrieves a cache entry in the same way as DataContainer.get(Object)} except that it does not update or reorder any of the internal constructs. I.e., expiration does not happen, and in the case of the LRU container, the entry is not moved to the end of the chain. This method should be used instead of DataContainer.get(Object)} when called while iterating through the data container using methods like DataContainer.keySet() to avoid changing the underlying collection's order.

Specified by:

peek in interface DataContainer

Parameters:

key - key under which entry is stored

Returns:

entry, if it exists, or null if not

get

public InternalCacheEntry get(Object k)

Description copied from interface: DataContainer

Retrieves a cached entry

Specified by:

get in interface DataContainer

Parameters:

k - key under which entry is stored

Returns:

entry, if it exists and has not expired, or null if not

put

public void put(Object k,
       Object v,
       Metadata metadata)

Description copied from interface: DataContainer

Puts an entry in the cache along with metadata adding information such lifespan of entry, max idle time, version information...etc.

Specified by:

put in interface DataContainer

Parameters:

k - key under which to store entry

v - value to store

metadata - metadata of the entry

containsKey

public boolean containsKey(Object k)

Description copied from interface: DataContainer

Tests whether an entry exists in the container

Specified by:

containsKey in interface DataContainer

Parameters:

k - key to test

Returns:

true if entry exists and has not expired; false otherwise

remove

public InternalCacheEntry remove(Object k)

Description copied from interface: DataContainer

Removes an entry from the cache

Specified by:

remove in interface DataContainer

Parameters:

k - key to remove

Returns:

entry removed, or null if it didn't exist or had expired

size

public int size()

Specified by:

size in interface DataContainer

Returns:

count of the number of entries in the container

clear

public void clear()

Description copied from interface: DataContainer

Removes all entries in the container

Specified by:

clear in interface DataContainer

keySet

public Set<Object> keySet()

Description copied from interface: DataContainer

Returns a set of keys in the container. When iterating through the container using this method, clients should never call #get() method but instead #peek(), in order to avoid changing the order of the underlying collection as a side of effect of iterating through it.

Specified by:

keySet in interface DataContainer

Returns:

a set of keys

values

public Collection<Object> values()

Specified by:

values in interface DataContainer

Returns:

a set of values contained in the container

entrySet

public Set<InternalCacheEntry> entrySet()

Description copied from interface: DataContainer

Returns a mutable set of immutable cache entries exposed as immutable Map.Entry instances. Clients of this method such as Cache.entrySet() operation implementors are free to convert the set into an immutable set if needed, which is the most common use case. If a client needs to iterate through a mutable set of mutable cache entries, it should iterate the container itself rather than iterating through the return of entrySet().

Specified by:

entrySet in interface DataContainer

Returns:

a set of immutable cache entries

purgeExpired

public void purgeExpired()

Description copied from interface: DataContainer

Purges entries that have passed their expiry time

Specified by:

purgeExpired in interface DataContainer

iterator

public Iterator<InternalCacheEntry> iterator()

Specified by:

iterator in interface Iterable<InternalCacheEntry>