Package org.infinispan.container.offheap

Class OffHeapConcurrentMap

java.lang.Object

org.infinispan.container.offheap.OffHeapConcurrentMap

All Implemented Interfaces:

java.util.concurrent.ConcurrentMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>, java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>, Lifecycle, PeekableMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>, org.infinispan.container.impl.PeekableTouchableMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>, org.infinispan.container.impl.TouchableMap

public class OffHeapConcurrentMap
extends java.lang.Object
implements java.util.concurrent.ConcurrentMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>, org.infinispan.container.impl.PeekableTouchableMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>, Lifecycle

Since:

9.4

Author:

wburns

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	OffHeapConcurrentMap.EntryListener	Listener interface that is notified when certain operations occur for various memory addresses.

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

java.util.Map.Entry<K extends java.lang.Object,V extends java.lang.Object>

Constructor Summary

Constructors

Constructor	Description
OffHeapConcurrentMap(int desiredSize, OffHeapMemoryAllocator allocator, OffHeapEntryFactory offHeapEntryFactory, OffHeapConcurrentMap.EntryListener listener)

Method Summary

Modifier and Type	Method	Description
void	clear()
InternalCacheEntry<WrappedBytes,WrappedBytes>	compute(WrappedBytes key, java.util.function.BiFunction<? super WrappedBytes,? super InternalCacheEntry<WrappedBytes,WrappedBytes>,? extends InternalCacheEntry<WrappedBytes,WrappedBytes>> remappingFunction)
boolean	containsKey(java.lang.Object key)
boolean	containsValue(java.lang.Object value)
java.util.Set<java.util.Map.Entry<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>>	entrySet()
InternalCacheEntry<WrappedBytes,WrappedBytes>	get(java.lang.Object key)
StripedLock	getLocks()
boolean	isEmpty()
java.util.Set<WrappedBytes>	keySet()
InternalCacheEntry<WrappedBytes,WrappedBytes>	peek(java.lang.Object key)	Peaks at a value for the given key.
InternalCacheEntry<WrappedBytes,WrappedBytes>	put(WrappedBytes key, InternalCacheEntry<WrappedBytes,WrappedBytes> value)
void	putAll(java.util.Map<? extends WrappedBytes,? extends InternalCacheEntry<WrappedBytes,WrappedBytes>> m)
InternalCacheEntry<WrappedBytes,WrappedBytes>	putIfAbsent(WrappedBytes key, InternalCacheEntry<WrappedBytes,WrappedBytes> value)
InternalCacheEntry<WrappedBytes,WrappedBytes>	remove(java.lang.Object key)
boolean	remove(java.lang.Object key, java.lang.Object value)
InternalCacheEntry<WrappedBytes,WrappedBytes>	replace(WrappedBytes key, InternalCacheEntry<WrappedBytes,WrappedBytes> value)
boolean	replace(WrappedBytes key, InternalCacheEntry<WrappedBytes,WrappedBytes> oldValue, InternalCacheEntry<WrappedBytes,WrappedBytes> newValue)
int	size()
void	start()	Invoked on component start
void	stop()	Invoked on component stop
boolean	touchKey(java.lang.Object key, long currentTimeMillis)	Touches the entry for the given key in this map.
java.util.Collection<InternalCacheEntry<WrappedBytes,WrappedBytes>>	values()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.concurrent.ConcurrentMap

computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, replaceAll

Methods inherited from interface java.util.Map

equals, hashCode

Constructor Detail

OffHeapConcurrentMap

public OffHeapConcurrentMap(int desiredSize,
                            OffHeapMemoryAllocator allocator,
                            OffHeapEntryFactory offHeapEntryFactory,
                            OffHeapConcurrentMap.EntryListener listener)

Method Detail

touchKey

public boolean touchKey(java.lang.Object key,
                        long currentTimeMillis)

Description copied from interface: org.infinispan.container.impl.TouchableMap

Touches the entry for the given key in this map. This method will update any recency timestamps for both expiration or eviction as needed.

Specified by:

touchKey in interface org.infinispan.container.impl.TouchableMap

Parameters:

key - key to touch

currentTimeMillis - the recency timestamp to set

Returns:

whether the entry was touched or not

getLocks

public StripedLock getLocks()

start

public void start()

Description copied from interface: Lifecycle

Invoked on component start

Specified by:

start in interface Lifecycle

stop

public void stop()

Description copied from interface: Lifecycle

Invoked on component stop

Specified by:

stop in interface Lifecycle

size

public int size()

Specified by:

size in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

compute

public InternalCacheEntry<WrappedBytes,WrappedBytes> compute(WrappedBytes key,
                                                                   java.util.function.BiFunction<? super WrappedBytes,? super InternalCacheEntry<WrappedBytes,WrappedBytes>,? extends InternalCacheEntry<WrappedBytes,WrappedBytes>> remappingFunction)

Specified by:

compute in interface java.util.concurrent.ConcurrentMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

Specified by:

compute in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

containsKey

public boolean containsKey(java.lang.Object key)

Specified by:

containsKey in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

containsValue

public boolean containsValue(java.lang.Object value)

Specified by:

containsValue in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

get

public InternalCacheEntry<WrappedBytes,WrappedBytes> get(java.lang.Object key)

Specified by:

get in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

peek

public InternalCacheEntry<WrappedBytes,WrappedBytes> peek(java.lang.Object key)

Description copied from interface: PeekableMap

Peaks at a value for the given key. Note that this does not update any expiration or eviction information when this is performed on the map, unlike the get method.

Specified by:

peek in interface PeekableMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

Parameters:

key - The key to find the value for

Returns:

The value mapping to this key

put

public InternalCacheEntry<WrappedBytes,WrappedBytes> put(WrappedBytes key,
                                                               InternalCacheEntry<WrappedBytes,WrappedBytes> value)

Specified by:

put in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

remove

public InternalCacheEntry<WrappedBytes,WrappedBytes> remove(java.lang.Object key)

Specified by:

remove in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

putAll

public void putAll(java.util.Map<? extends WrappedBytes,? extends InternalCacheEntry<WrappedBytes,WrappedBytes>> m)

Specified by:

putAll in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

clear

public void clear()

Specified by:

clear in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

putIfAbsent

public InternalCacheEntry<WrappedBytes,WrappedBytes> putIfAbsent(WrappedBytes key,
                                                                       InternalCacheEntry<WrappedBytes,WrappedBytes> value)

Specified by:

putIfAbsent in interface java.util.concurrent.ConcurrentMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

Specified by:

putIfAbsent in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

remove

public boolean remove(java.lang.Object key,
                      java.lang.Object value)

Specified by:

remove in interface java.util.concurrent.ConcurrentMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

Specified by:

remove in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

replace

public boolean replace(WrappedBytes key,
                       InternalCacheEntry<WrappedBytes,WrappedBytes> oldValue,
                       InternalCacheEntry<WrappedBytes,WrappedBytes> newValue)

Specified by:

replace in interface java.util.concurrent.ConcurrentMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

Specified by:

replace in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

replace

public InternalCacheEntry<WrappedBytes,WrappedBytes> replace(WrappedBytes key,
                                                                   InternalCacheEntry<WrappedBytes,WrappedBytes> value)

Specified by:

replace in interface java.util.concurrent.ConcurrentMap<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

Specified by:

replace in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

keySet

public java.util.Set<WrappedBytes> keySet()

Specified by:

keySet in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

values

public java.util.Collection<InternalCacheEntry<WrappedBytes,WrappedBytes>> values()

Specified by:

values in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>

entrySet

public java.util.Set<java.util.Map.Entry<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>> entrySet()

Specified by:

entrySet in interface java.util.Map<WrappedBytes,InternalCacheEntry<WrappedBytes,WrappedBytes>>