org.infinispan.atomic
Class AtomicHashMapProxy<K,V>
java.lang.Object
org.infinispan.batch.AutoBatchSupport
org.infinispan.atomic.AtomicHashMapProxy<K,V>
- Type Parameters:
K
- the type of keys maintained by this mapV
- the type of mapped values
- All Implemented Interfaces:
- Map<K,V>, AtomicMap<K,V>
- Direct Known Subclasses:
- FineGrainedAtomicHashMapProxy
public class AtomicHashMapProxy<K,V>
- extends AutoBatchSupport
- implements AtomicMap<K,V>
A layer of indirection around an AtomicHashMap
to provide consistency and isolation for concurrent readers
while writes may also be going on. The techniques used in this implementation are very similar to the lock-free
reader MVCC model used in the MVCCEntry
implementations for the core data
container, which closely follow software transactional memory approaches to dealing with concurrency.
Implementations of this class are rarely created on their own; AtomicHashMap.getProxy(org.infinispan.AdvancedCache, Object, boolean, org.infinispan.context.FlagContainer)
}
should be used to retrieve an instance of this proxy.
Typically proxies are only created by the AtomicMapLookup
helper, and would not be created by end-user code
directly.
- Since:
- 4.0
- Author:
- Manik Surtani
- See Also:
AtomicHashMap
Nested classes/interfaces inherited from interface java.util.Map |
Map.Entry<K,V> |
deltaMapKey
protected final Object deltaMapKey
cache
protected final AdvancedCache<Object,AtomicMap<K,V>> cache
cacheForWriting
protected final AdvancedCache<Object,AtomicMap<K,V>> cacheForWriting
startedReadingMap
protected volatile boolean startedReadingMap
flagContainer
protected final FlagContainer flagContainer
transactionTable
protected TransactionTable transactionTable
transactionManager
protected TransactionManager transactionManager
toMap
protected AtomicHashMap<K,V> toMap(Object object)
getDeltaMapForRead
protected AtomicHashMap<K,V> getDeltaMapForRead()
lookupEntryFromCurrentTransaction
protected CacheEntry lookupEntryFromCurrentTransaction()
- Looks up the CacheEntry stored in transactional context corresponding to this AtomicMap. If this AtomicMap
has yet to be touched by the current transaction, this method will return a null.
- Returns:
getDeltaMapForWrite
protected AtomicHashMap<K,V> getDeltaMapForWrite()
assertValid
protected void assertValid(AtomicHashMap<?,?> map)
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>
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>
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> m)
- Specified by:
putAll
in interface Map<K,V>
clear
public void clear()
- Specified by:
clear
in interface Map<K,V>
toString
public String toString()
- Overrides:
toString
in class Object
Copyright © 2012 JBoss, a division of Red Hat. All Rights Reserved.