org.apache.ignite.internal.processors.cache

Class GridCacheConcurrentMapImpl

java.lang.Object

org.apache.ignite.internal.processors.cache.GridCacheConcurrentMapImpl

All Implemented Interfaces:

GridCacheConcurrentMap

Direct Known Subclasses:

GridCacheLocalConcurrentMap, GridDhtLocalPartition

public abstract class GridCacheConcurrentMapImpl
extends Object
implements GridCacheConcurrentMap

Implementation of concurrent cache map.

Constructor Summary

Constructors

Constructor and Description
GridCacheConcurrentMapImpl(GridCacheContext ctx, GridCacheMapEntryFactory factory, int initialCapacity) Creates a new, empty map with the specified initial capacity.
GridCacheConcurrentMapImpl(GridCacheContext ctx, GridCacheMapEntryFactory factory, int initialCapacity, float loadFactor, int concurrencyLevel) Creates a new, empty map with the specified initial capacity, load factor and concurrency level.

Method Summary

Methods

Modifier and Type	Method and Description
Collection<GridCacheMapEntry>	allEntries(CacheEntryPredicate... filter)
Collection<GridCacheMapEntry>	entries(CacheEntryPredicate... filter)
Set<GridCacheMapEntry>	entrySet(CacheEntryPredicate... filter)
GridCacheMapEntry	getEntry(KeyCacheObject key) Returns the entry associated with the specified key in the HashMap.
Set<KeyCacheObject>	keySet(CacheEntryPredicate... filter)
GridCacheMapEntry	putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer, KeyCacheObject key, CacheObject val, boolean create, boolean touch)
protected void	release()
protected void	release(int sizeChange, GridCacheEntryEx e)
boolean	removeEntry(GridCacheEntryEx entry) Removes passed in entry if it presents in the map.
protected boolean	reserve()
int	size() Returns the number of key-value mappings in this map.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.ignite.internal.processors.cache.GridCacheConcurrentMap

decrementPublicSize, incrementPublicSize, publicSize

Constructor Detail

GridCacheConcurrentMapImpl

public GridCacheConcurrentMapImpl(GridCacheContext ctx,
                          GridCacheMapEntryFactory factory,
                          int initialCapacity)

Creates a new, empty map with the specified initial capacity.

Parameters:

ctx - Cache context.

factory - Entry factory.

initialCapacity - the initial capacity. The implementation performs internal sizing to accommodate this many elements.

Throws:

IllegalArgumentException - if the initial capacity is negative.

GridCacheConcurrentMapImpl

public GridCacheConcurrentMapImpl(GridCacheContext ctx,
                          GridCacheMapEntryFactory factory,
                          int initialCapacity,
                          float loadFactor,
                          int concurrencyLevel)

Creates a new, empty map with the specified initial capacity, load factor and concurrency level.

Parameters:

ctx - Cache context.

factory - Entry factory.

initialCapacity - the initial capacity. The implementation performs internal sizing to accommodate this many elements.

loadFactor - the load factor threshold, used to control resizing. Resizing may be performed when the average number of elements per bin exceeds this threshold.

concurrencyLevel - the estimated number of concurrently updating threads. The implementation performs internal sizing to try to accommodate this many threads.

Throws:

IllegalArgumentException - if the initial capacity is negative or the load factor or concurrencyLevel are non-positive.

Method Detail

getEntry

@Nullable
public GridCacheMapEntry getEntry(KeyCacheObject key)

Returns the entry associated with the specified key in the HashMap. Returns null if the HashMap contains no mapping for this key.

Specified by:

getEntry in interface GridCacheConcurrentMap

Parameters:

key - Key.

Returns:

Entry.

putEntryIfObsoleteOrAbsent

@Nullable
public GridCacheMapEntry putEntryIfObsoleteOrAbsent(AffinityTopologyVersion topVer,
                                                    KeyCacheObject key,
                                                    @Nullable
                                                    CacheObject val,
                                                    boolean create,
                                                    boolean touch)

Specified by:

putEntryIfObsoleteOrAbsent in interface GridCacheConcurrentMap

Parameters:

topVer - Topology version.

key - Key.

val - Value.

create - Create flag.

Returns:

Existing or new GridCacheMapEntry. Will return null if entry is obsolete or absent and create flag is set to false. Will also return null if create flag is set to true, but entry couldn't be created.

reserve

protected boolean reserve()

release

protected void release()

release

protected void release(int sizeChange,
           GridCacheEntryEx e)

Parameters:

sizeChange - Size delta.

e - Map entry.

removeEntry

public boolean removeEntry(GridCacheEntryEx entry)

Removes passed in entry if it presents in the map.

Specified by:

removeEntry in interface GridCacheConcurrentMap

Parameters:

entry - Entry to remove.

Returns:

True if remove happened.

size

public int size()

Returns the number of key-value mappings in this map. It does not include entries from underlying data store.

Specified by:

size in interface GridCacheConcurrentMap

Returns:

the number of key-value mappings in this map.

keySet

public Set<KeyCacheObject> keySet(CacheEntryPredicate... filter)

Specified by:

keySet in interface GridCacheConcurrentMap

Returns:

Random entry out of hash map.

entries

public Collection<GridCacheMapEntry> entries(CacheEntryPredicate... filter)

Specified by:

entries in interface GridCacheConcurrentMap

Parameters:

filter - Filter.

Returns:

Iterable of the mappings contained in this map, excluding entries in unvisitable state.

allEntries

public Collection<GridCacheMapEntry> allEntries(CacheEntryPredicate... filter)

Specified by:

allEntries in interface GridCacheConcurrentMap

Parameters:

filter - Filter.

Returns:

Iterable of the mappings contained in this map, including entries in unvisitable state.

entrySet

public Set<GridCacheMapEntry> entrySet(CacheEntryPredicate... filter)

Specified by:

entrySet in interface GridCacheConcurrentMap

Parameters:

filter - Filter.

Returns:

Set of the mappings contained in this map.