Package com.tangosol.util

Class WrapperCollections.ConcurrentWrapperMap<K,V>

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,V>

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