java.lang.Object

com.tangosol.util.WrapperCollections.ConcurrentWrapperMap<K,V>

All Implemented Interfaces:: ConcurrentMap<K,V>, Map<K,V>

Enclosing class:: WrapperCollections

public static class WrapperCollections.ConcurrentWrapperMap<K,V> extends Object implements ConcurrentMap<K,V>

Map implementation which uses a ReadWriteLock to manage concurrent access to an underlying Map.

Since:: Coherence 3.7

Nested Class Summary

Nested classes/interfaces inherited from interface java.util.Map
Map.Entry<K extends Object,V extends Object>
Field Summary

Fields

Modifier and Type

Field

Description

protected Collection<V>

m_collValues

The values collection.

protected final boolean

m_fStrict

Determines whether or not all of the Entry methods are protected; if set to true, then all Entry methods are protected.

protected final ReadWriteLock

m_lock

The read/write lock for concurrency control.

protected final Lock

m_lockExclusive

The exclusive lock for performing read/write operations.

protected final Lock

m_lockShared

The shared lock for performing read operations.

protected Map<K,V>

m_mapDelegate

The Map to which this wrapper delegates.

protected Set<Map.Entry<K,V>>

m_setEntries

The entry set.

protected Set<K>

m_setKeys

The key set.
Constructor Summary

Constructors

Modifier

Constructor

Description

protected

ConcurrentWrapperMap()

ConcurrentWrapperMap(Map<K,V> map)

Create an ConcurrentWrapperMap which delegates to the specified Map.

protected

ConcurrentWrapperMap(Map<K,V> map, ReadWriteLock lock)

Create an ConcurrentWrapperMap which delegates to the specified Map.

protected

ConcurrentWrapperMap(Map<K,V> map, ReadWriteLock lock, boolean fStrict)

Create an ConcurrentWrapperMap which delegates to the specified Map.
Method Summary

Modifier and Type

Method

Description

void

clear()

V

compute(K key, BiFunction<? super K,? super V,? extends V> remappingFunction)

V

computeIfAbsent(K key, Function<? super K,? extends V> mappingFunction)

V

computeIfPresent(K key, BiFunction<? super K,? super V,? extends V> remappingFunction)

boolean

containsKey(Object oKey)

boolean

containsValue(Object oValue)

Set<Map.Entry<K,V>>

entrySet()

boolean

equals(Object oOther)

void

forEach(BiConsumer<? super K,? super V> action)

V

get(Object oKey)

protected Map<K,V>

getDelegate()

Return the Map to which all operations should be delegated to.

protected ReadWriteLock

getLock()

Return the ReadWriteLock that is used to manage concurrent access and modifications to the underlying map.

V

getOrDefault(Object key, V defaultValue)

int

hashCode()

boolean

isEmpty()

Set<K>

keySet()

V

merge(K key, V value, BiFunction<? super V,? super V,? extends V> remappingFunction)

V

put(K oKey, V oValue)

void

putAll(Map<? extends K,? extends V> map)

V

putIfAbsent(K key, V value)

V

remove(Object oKey)

boolean

remove(Object key, Object value)

V

replace(K key, V value)

boolean

replace(K key, V oldValue, V newValue)

void

replaceAll(BiFunction<? super K,? super V,? extends V> function)

int

size()

String

toString()

Collection<V>

values()

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Field Details
- m_mapDelegate
  
  protected Map<K,V> m_mapDelegate
  
  The Map to which this wrapper delegates.
- m_lock
  
  protected final ReadWriteLock m_lock
  
  The read/write lock for concurrency control.
- m_lockShared
  
  protected final Lock m_lockShared
  
  The shared lock for performing read operations.
- m_lockExclusive
  
  protected final Lock m_lockExclusive
  
  The exclusive lock for performing read/write operations.
- m_setKeys
  
  protected Set<K> m_setKeys
  
  The key set.
- m_setEntries
  
  protected Set<Map.Entry<K,V>> m_setEntries
  
  The entry set.
- m_collValues
  
  protected Collection<V> m_collValues
  
  The values collection.
- m_fStrict
  
  protected final boolean m_fStrict
  
  Determines whether or not all of the Entry methods are protected; if set to true, then all Entry methods are protected.
Constructor Details
- ConcurrentWrapperMap
  
  protected ConcurrentWrapperMap()
- ConcurrentWrapperMap
  
  public ConcurrentWrapperMap(Map<K,V> map)
  
  Create an ConcurrentWrapperMap which delegates to the specified Map.
  
  Parameters:
  
  map - the Map to delegate all calls to
- ConcurrentWrapperMap
  
  protected ConcurrentWrapperMap(Map<K,V> map, ReadWriteLock lock)
  
  Create an ConcurrentWrapperMap which delegates to the specified Map.
  
  Parameters:
  
  map - the Map to delegate all calls to
  
  lock - a read/write lock for concurrency management
- ConcurrentWrapperMap
  
  protected ConcurrentWrapperMap(Map<K,V> map, ReadWriteLock lock, boolean fStrict)
  
  Create an ConcurrentWrapperMap which delegates to the specified Map.
  
  Parameters:
  
  map - the Map to delegate all calls to
  
  lock - a read/write lock for concurrency management
  
  fStrict - pass true to protect all Entry methods; false to protect only the setValue() method
Method Details
- getDelegate
  
  protected Map<K,V> getDelegate()
  
  Return the Map to which all operations should be delegated to.
  
  Returns:
  
  the wrapped Map
- getLock
  
  protected ReadWriteLock getLock()
  
  Return the ReadWriteLock that is used to manage concurrent access and modifications to the underlying map.
  
  Returns:
  
  the ReadWriteLock
- clear
  
  public void clear()
  
  Specified by:
  
  clear in interface Map<K,V>
- containsKey
  
  public boolean containsKey(Object oKey)
  
  Specified by:
  
  containsKey in interface Map<K,V>
- containsValue
  
  public boolean containsValue(Object oValue)
  
  Specified by:
  
  containsValue in interface Map<K,V>
- entrySet
  
  public Set<Map.Entry<K,V>> entrySet()
  
  Specified by:
  
  entrySet in interface Map<K,V>
- get
  
  public V get(Object oKey)
  
  Specified by:
  
  get in interface Map<K,V>
- isEmpty
  
  public boolean isEmpty()
  
  Specified by:
  
  isEmpty in interface Map<K,V>
- keySet
  
  public Set<K> keySet()
  
  Specified by:
  
  keySet in interface Map<K,V>
- put
  
  public V put(K oKey, V oValue)
  
  Specified by:
  
  put in interface Map<K,V>
- putAll
  
  public void putAll(Map<? extends K,? extends V> map)
  
  Specified by:
  
  putAll in interface Map<K,V>
- putIfAbsent
  
  public V putIfAbsent(K key, V value)
  
  Specified by:
  
  putIfAbsent in interface ConcurrentMap<K,V>
  
  Specified by:
  
  putIfAbsent in interface Map<K,V>
- remove
  
  public V remove(Object oKey)
  
  Specified by:
  
  remove in interface Map<K,V>
- remove
  
  public boolean remove(Object key, Object value)
  
  Specified by:
  
  remove in interface ConcurrentMap<K,V>
  
  Specified by:
  
  remove in interface Map<K,V>
- replace
  
  public V replace(K key, V value)
  
  Specified by:
  
  replace in interface ConcurrentMap<K,V>
  
  Specified by:
  
  replace in interface Map<K,V>
- replace
  
  public boolean replace(K key, V oldValue, V newValue)
  
  Specified by:
  
  replace in interface ConcurrentMap<K,V>
  
  Specified by:
  
  replace in interface Map<K,V>
- size
  
  public int size()
  
  Specified by:
  
  size in interface Map<K,V>
- values
  
  public Collection<V> values()
  
  Specified by:
  
  values in interface Map<K,V>
- getOrDefault
  
  public V getOrDefault(Object key, V defaultValue)
  
  Specified by:
  
  getOrDefault in interface ConcurrentMap<K,V>
  
  Specified by:
  
  getOrDefault in interface Map<K,V>
- forEach
  
  public void forEach(BiConsumer<? super K,? super V> action)
  
  Specified by:
  
  forEach in interface ConcurrentMap<K,V>
  
  Specified by:
  
  forEach in interface Map<K,V>
- replaceAll
  
  public void replaceAll(BiFunction<? super K,? super V,? extends V> function)
  
  Specified by:
  
  replaceAll in interface ConcurrentMap<K,V>
  
  Specified by:
  
  replaceAll in interface Map<K,V>
- computeIfAbsent
  
  public V computeIfAbsent(K key, Function<? super K,? extends V> mappingFunction)
  
  Specified by:
  
  computeIfAbsent in interface ConcurrentMap<K,V>
  
  Specified by:
  
  computeIfAbsent in interface Map<K,V>
- computeIfPresent
  
  public V computeIfPresent(K key, BiFunction<? super K,? super V,? extends V> remappingFunction)
  
  Specified by:
  
  computeIfPresent in interface ConcurrentMap<K,V>
  
  Specified by:
  
  computeIfPresent in interface Map<K,V>
- compute
  
  public V compute(K key, BiFunction<? super K,? super V,? extends V> remappingFunction)
  
  Specified by:
  
  compute in interface ConcurrentMap<K,V>
  
  Specified by:
  
  compute in interface Map<K,V>
- merge
  
  public V merge(K key, V value, BiFunction<? super V,? super V,? extends V> remappingFunction)
  
  Specified by:
  
  merge in interface ConcurrentMap<K,V>
  
  Specified by:
  
  merge in interface Map<K,V>
- equals
  
  public boolean equals(Object oOther)
  
  Specified by:
  
  equals in interface Map<K,V>
  
  Overrides:
  
  equals in class Object
- hashCode
  
  public int hashCode()
  
  Specified by:
  
  hashCode in interface Map<K,V>
  
  Overrides:
  
  hashCode in class Object
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object

Class WrapperCollections.ConcurrentWrapperMap<K,V>

Nested Class Summary

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

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Details

m_mapDelegate

m_lock

m_lockShared

m_lockExclusive

m_setKeys

m_setEntries

m_collValues

m_fStrict

Constructor Details

ConcurrentWrapperMap

ConcurrentWrapperMap

ConcurrentWrapperMap

ConcurrentWrapperMap

Method Details

getDelegate

getLock

clear

containsKey

containsValue

entrySet

get

isEmpty

keySet

put

putAll

putIfAbsent

remove

remove

replace

replace

size

values

getOrDefault

forEach

replaceAll

computeIfAbsent

computeIfPresent

compute

merge

equals

hashCode

toString