com.tangosol.util

Class ConverterCollections.ConverterConcurrentMap<FK,TK,FV,TV>

java.lang.Object

com.tangosol.util.ConverterCollections.ConverterMap<FK,TK,FV,TV>

com.tangosol.util.ConverterCollections.ConverterConcurrentMap<FK,TK,FV,TV>

All Implemented Interfaces:

ConcurrentMap<TK,TV>, Serializable, Map<TK,TV>

Enclosing class:

ConverterCollections

public static class ConverterCollections.ConverterConcurrentMap<FK,TK,FV,TV>
extends ConverterCollections.ConverterMap<FK,TK,FV,TV>
implements ConcurrentMap<TK,TV>, Serializable

A Converter ConcurrentMap views an underlying ConcurrentMap through a set of key and value Converters.

Nested Class Summary

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

Map.Entry<K,V>

Field Summary

Fields inherited from class com.tangosol.util.ConverterCollections.ConverterMap

m_convKeyDown, m_convKeyUp, m_convValDown, m_convValUp, m_map, m_set

Fields inherited from interface com.tangosol.util.ConcurrentMap

LOCK_ALL

Constructor Summary

Constructors

Constructor and Description
ConverterConcurrentMap(ConcurrentMap<FK,FV> map, Converter<FK,TK> convKeyUp, Converter<TK,FK> convKeyDown, Converter<FV,TV> convValUp, Converter<TV,FV> convValDown) Constructor.

Method Summary

Modifier and Type	Method and Description
ConcurrentMap<FK,FV>	getConcurrentMap() Return the underlying ConcurrentMap.
boolean	lock(Object oKey) Attempt to lock the specified item and return immediately.
boolean	lock(Object oKey, long cWait) Attempt to lock the specified item within the specified period of time.
boolean	unlock(Object oKey) Unlock the specified item.

Methods inherited from class com.tangosol.util.ConverterCollections.ConverterMap

clear, containsKey, containsValue, entrySet, equals, get, getConverterKeyDown, getConverterKeyUp, getConverterValueDown, getConverterValueUp, getMap, hashCode, instantiateCollection, instantiateEntrySet, instantiateMap, instantiateSet, isEmpty, keySet, put, putAll, remove, size, toString, values

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface com.tangosol.util.ConcurrentMap

clear, containsKey, containsValue, get, isEmpty, put, putAll, remove, size

Methods inherited from interface java.util.Map

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

Constructor Detail

ConverterConcurrentMap

public ConverterConcurrentMap(ConcurrentMap<FK,FV> map,
                              Converter<FK,TK> convKeyUp,
                              Converter<TK,FK> convKeyDown,
                              Converter<FV,TV> convValUp,
                              Converter<TV,FV> convValDown)

Constructor.

Parameters:

map - the underlying ConcurrentMap

convKeyUp - the Converter to view the underlying ConcurrentMap's keys through

convKeyDown - the Converter to use to pass keys down to the underlying ConcurrentMap

convValUp - the Converter to view the underlying ConcurrentMap's values through

convValDown - the Converter to use to pass values down to the underlying ConcurrentMap

Method Detail

lock

public boolean lock(Object oKey)

Attempt to lock the specified item and return immediately.

This method behaves exactly as if it simply performs the call lock(oKey, 0).

Specified by:

lock in interface ConcurrentMap<TK,TV>

Parameters:

oKey - key being locked

Returns:

true if the item was successfully locked; false otherwise

lock

public boolean lock(Object oKey,
                    long cWait)

Attempt to lock the specified item within the specified period of time.

The item doesn't have to exist to be locked. While the item is locked there is known to be a lock holder which has an exclusive right to modify (calling put and remove methods) that item.

Lock holder is an abstract concept that depends on the ConcurrentMap implementation. For example, holder could be a cluster member or a thread (or both).

Locking strategy may vary for concrete implementations as well. Lock could have an expiration time (this lock is sometimes called a "lease") or be held indefinitely (until the lock holder terminates).

Some implementations may allow the entire map to be locked. If the map is locked in such a way, then only a lock holder is allowed to perform any of the "put" or "remove" operations. Pass the special constant ConcurrentMap.LOCK_ALL as the oKey parameter to indicate the map lock.

Specified by:

lock in interface ConcurrentMap<TK,TV>

Parameters:

oKey - key being locked

cWait - the number of milliseconds to continue trying to obtain a lock; pass zero to return immediately; pass -1 to block the calling thread until the lock could be obtained

Returns:

true if the item was successfully locked within the specified time; false otherwise

unlock

public boolean unlock(Object oKey)

Unlock the specified item. The item doesn't have to exist to be unlocked. If the item is currently locked, only the holder of the lock could successfully unlock it.

Specified by:

unlock in interface ConcurrentMap<TK,TV>

Parameters:

oKey - key being unlocked

Returns:

true if the item was successfully unlocked; false otherwise

getConcurrentMap

public ConcurrentMap<FK,FV> getConcurrentMap()

Return the underlying ConcurrentMap.

Returns:

the underlying ConcurrentMap