Class AbstractConcurrentOffHeapCache<K,V>

java.lang.Object

java.util.AbstractMap<K,V>

org.terracotta.offheapstore.concurrent.AbstractConcurrentOffHeapMap<K,V>

org.terracotta.offheapstore.concurrent.AbstractConcurrentOffHeapCache<K,V>

All Implemented Interfaces:

ConcurrentMap<K,V>, Map<K,V>, ConcurrentMapInternals, HashingMap<K,V>, MapInternals, PinnableCache<K,V>

Direct Known Subclasses:

AbstractPersistentConcurrentOffHeapCache, ConcurrentOffHeapClockCache, ConcurrentWriteLockedOffHeapClockCache

public abstract class AbstractConcurrentOffHeapCache<K,V>
extends AbstractConcurrentOffHeapMap<K,V>
implements PinnableCache<K,V>

Nested Class Summary

Nested classes/interfaces inherited from class AbstractConcurrentOffHeapMap

AbstractConcurrentOffHeapMap.AggregatedValuesCollection, AbstractConcurrentOffHeapMap.AggregateEntrySet, AbstractConcurrentOffHeapMap.AggregateIterator<T>, AbstractConcurrentOffHeapMap.AggregateKeySet

Nested classes/interfaces inherited from class AbstractMap

AbstractMap.SimpleEntry<K,V>, AbstractMap.SimpleImmutableEntry<K,V>

Nested classes/interfaces inherited from interface Map

Map.Entry<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
private static final Comparator<Segment<?,?>>	SIZE_COMPARATOR

Fields inherited from class AbstractConcurrentOffHeapMap

segments

Constructor Summary

Constructors

Constructor	Description
AbstractConcurrentOffHeapCache(Factory<? extends PinnableSegment<K,V>> segmentFactory)
AbstractConcurrentOffHeapCache(Factory<? extends Segment<K,V>> segmentFactory, int concurrency)

Method Summary

Modifier and Type	Method	Description
V	fill(K key, V value)	See OffHeapHashMap.fill(Object, Object) for a detailed description.
V	getAndPin(K key)
boolean	isPinned(Object key)
V	putPinned(K key, V value)
protected PinnableSegment<K,V>	segmentFor(Object key)
void	setPinning(K key, boolean pinned)
boolean	shrink()
boolean	shrinkOthers(int excludedHash)

Methods inherited from class AbstractConcurrentOffHeapMap

clear, computeIfAbsentWithMetadata, computeIfPresentWithMetadata, computeWithMetadata, containsKey, containsValue, destroy, entrySet, fill, get, getAllocatedMemory, getAndSetMetadata, getConcurrency, getDataAllocatedMemory, getDataOccupiedMemory, getDataSize, getDataVitalMemory, getIndexFor, getMetadata, getOccupiedMemory, getRemovedSlotCount, getReprobeLength, getSegmentInternals, getSegments, getSize, getTableCapacity, getUsedSlotCount, getValueAndSetMetadata, getVitalMemory, handleOversizeMappingException, keySet, put, put, putIfAbsent, readLockAll, readUnlockAll, remove, remove, removeAllWithHash, removeNoReturn, replace, replace, segmentFor, size, values, writeLockAll, writeUnlockAll

Methods inherited from class AbstractMap

clone, equals, hashCode, isEmpty, putAll, toString

Methods inherited from class Object

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

Methods inherited from interface ConcurrentMap

compute, computeIfAbsent, computeIfPresent, forEach, getOrDefault, merge, putIfAbsent, remove, replace, replace, replaceAll

Methods inherited from interface Map

clear, containsKey, containsValue, entrySet, equals, get, hashCode, isEmpty, keySet, put, putAll, remove, size, values

Field Details

SIZE_COMPARATOR

private static final Comparator<Segment<?,?>> SIZE_COMPARATOR

Constructor Details

AbstractConcurrentOffHeapCache

public AbstractConcurrentOffHeapCache(Factory<? extends PinnableSegment<K,V>> segmentFactory)

AbstractConcurrentOffHeapCache

public AbstractConcurrentOffHeapCache(Factory<? extends Segment<K,V>> segmentFactory,
 int concurrency)

Method Details

fill

public V fill(K key,
 V value)

Description copied from class: AbstractConcurrentOffHeapMap

See OffHeapHashMap.fill(Object, Object) for a detailed description.

Overrides:

fill in class AbstractConcurrentOffHeapMap<K,V>

Parameters:

key - key with which the specified value is to be associated

value - value to be associated with the specified key

Returns:

the previous value associated with key, or null if there was no mapping for key (irrespective of whether the value was successfully installed).

getAndPin

public V getAndPin(K key)

Specified by:

getAndPin in interface PinnableCache<K,V>

putPinned

public V putPinned(K key,
 V value)

Specified by:

putPinned in interface PinnableCache<K,V>

isPinned

public boolean isPinned(Object key)

Specified by:

isPinned in interface PinnableCache<K,V>

setPinning

public void setPinning(K key,
 boolean pinned)

Specified by:

setPinning in interface PinnableCache<K,V>

segmentFor

protected PinnableSegment<K,V> segmentFor(Object key)

Overrides:

segmentFor in class AbstractConcurrentOffHeapMap<K,V>

shrink

public boolean shrink()

shrinkOthers

public boolean shrinkOthers(int excludedHash)