org.infinispan.atomic.impl

Class AtomicHashMap<K,V>

java.lang.Object

org.infinispan.atomic.impl.AtomicHashMap<K,V>

Type Parameters:

K - the type of keys maintained by this map

V - the type of mapped values

All Implemented Interfaces:

Cloneable, Map<K,V>, AtomicMap<K,V>, CopyableDeltaAware, DeltaAware

@NotThreadSafe
public final class AtomicHashMap<K,V>
extends Object
implements AtomicMap<K,V>, CopyableDeltaAware, Cloneable

The default implementation of AtomicMap. Note that this map cannot be constructed directly, and callers should obtain references to AtomicHashMaps via the AtomicMapLookup helper. This helper will ensure proper concurrent construction and registration of AtomicMaps in Infinispan's data container. E.g.:

AtomicMap<String, Integer> map = AtomicMapLookup.getAtomicMap(cache, "my_atomic_map_key");

Note that for replication to work properly, AtomicHashMap updates must always take place within the scope of an ongoing JTA transaction or batch (see BatchingCache.startBatch()).

Since:

4.0

Author:

(various)

See Also:

AtomicMap, AtomicMapLookup

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AtomicHashMap.Externalizer
static class	AtomicHashMap.ProxyMode

Nested classes/interfaces inherited from interface java.util.Map

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field and Description
protected FastCopyHashMap<K,V>	delegate

Constructor Summary

Constructors

Constructor and Description
AtomicHashMap()
AtomicHashMap(AtomicHashMap.ProxyMode proxyMode)
AtomicHashMap(boolean isCopy, AtomicHashMap.ProxyMode proxyMode)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	commit() Indicate that all deltas collected to date has been extracted (via a call to DeltaAware.delta()) and can be discarded.
boolean	containsKey(Object key)
boolean	containsValue(Object value)
AtomicHashMap<K,V>	copy()
Delta	delta() Extracts changes made to implementations, in an efficient format that can easily and cheaply be serialized and deserialized.
Set<Map.Entry<K,V>>	entrySet()
V	get(Object key)
AtomicHashMapProxy<K,V>	getProxy(AdvancedCache<Object,Object> cache, Object mapKey) Builds a thread-safe proxy for this instance so that concurrent reads are isolated from writes.
void	initForWriting() Initializes the delta instance to start recording changes.
boolean	isEmpty()
Set<K>	keySet()
void	markRemoved(boolean b)
static <K,V> AtomicHashMap<K,V>	newInstance(Cache<Object,Object> cache, Object cacheKey, AtomicHashMap.ProxyMode proxyMode) Construction only allowed through this factory method.
V	put(K key, V value)
void	putAll(Map<? extends K,? extends V> t)
V	remove(Object key)
int	size()
String	toString()
Collection<V>	values()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Map

compute, computeIfAbsent, computeIfPresent, equals, forEach, getOrDefault, hashCode, merge, putIfAbsent, remove, replace, replace, replaceAll

Field Detail

delegate

protected final FastCopyHashMap<K,V> delegate

Constructor Detail

AtomicHashMap

public AtomicHashMap()

AtomicHashMap

public AtomicHashMap(AtomicHashMap.ProxyMode proxyMode)

AtomicHashMap

public AtomicHashMap(boolean isCopy,
                     AtomicHashMap.ProxyMode proxyMode)

Method Detail

newInstance

public static <K,V> AtomicHashMap<K,V> newInstance(Cache<Object,Object> cache,
                                                   Object cacheKey,
                                                   AtomicHashMap.ProxyMode proxyMode)

Construction only allowed through this factory method. This factory is intended for use internally by the CacheDelegate. User code should use AtomicMapLookup.getAtomicMap(Cache, Object).

commit

public void commit()

Description copied from interface: DeltaAware

Indicate that all deltas collected to date has been extracted (via a call to DeltaAware.delta()) and can be discarded. Often used as an optimization if the delta isn't really needed, but the cleaning and resetting of internal state is desirable.

Specified by:

commit in interface DeltaAware

size

public int size()

Specified by:

size in interface Map<K,V>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Map<K,V>

containsKey

public boolean containsKey(Object key)

Specified by:

containsKey in interface Map<K,V>

containsValue

public boolean containsValue(Object value)

Specified by:

containsValue in interface Map<K,V>

get

public V get(Object key)

Specified by:

get in interface Map<K,V>

keySet

public Set<K> keySet()

Specified by:

keySet in interface Map<K,V>

values

public Collection<V> values()

Specified by:

values in interface Map<K,V>

entrySet

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

Specified by:

entrySet in interface Map<K,V>

put

public V put(K key,
             V value)

Specified by:

put in interface Map<K,V>

remove

public V remove(Object key)

Specified by:

remove in interface Map<K,V>

putAll

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

Specified by:

putAll in interface Map<K,V>

clear

public void clear()

Specified by:

clear in interface Map<K,V>

getProxy

public AtomicHashMapProxy<K,V> getProxy(AdvancedCache<Object,Object> cache,
                                        Object mapKey)

Builds a thread-safe proxy for this instance so that concurrent reads are isolated from writes.

Returns:

an instance of AtomicHashMapProxy

markRemoved

public void markRemoved(boolean b)

delta

public Delta delta()

Description copied from interface: DeltaAware

Extracts changes made to implementations, in an efficient format that can easily and cheaply be serialized and deserialized. This method will only be called once for each changeset as it is assumed that any implementation's internal changelog is wiped and reset after generating and submitting the delta to the caller.

Specified by:

delta in interface DeltaAware

Returns:

an instance of Delta

copy

public AtomicHashMap<K,V> copy()

Specified by:

copy in interface CopyableDeltaAware

Returns:

a copy of this DeltaAware instance.

toString

public String toString()

Overrides:

toString in class Object

initForWriting

public void initForWriting()

Initializes the delta instance to start recording changes.