Package one.nio.mem

Class OffheapMap<K,V>

java.lang.Object

one.nio.mem.OffheapMap<K,V>

All Implemented Interfaces:

OffheapMapMXBean

Direct Known Subclasses:

OffheapBlobMap, SharedMemoryMap

public abstract class OffheapMap<K,V>
extends java.lang.Object
implements OffheapMapMXBean

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	OffheapMap.BasicCleanup
static class	OffheapMap.Record<K,V>
class	OffheapMap.SamplingCleanup
static interface	OffheapMap.Visitor<K,V>
static class	OffheapMap.WritableRecord<K,V>
static interface	OffheapMap.WritableVisitor<K,V>

Field Summary

Fields

Modifier and Type	Field	Description
protected static long	byteArrayOffset
protected int	capacity
protected long	cleanupInterval
protected OffheapMap.BasicCleanup	cleanupThread
protected double	cleanupThreshold
protected static int	CONCURRENCY_LEVEL
protected java.util.concurrent.atomic.AtomicInteger	count
protected java.util.concurrent.atomic.AtomicLong	expirations
protected static int	HASH_OFFSET
protected static int	HEADER_SIZE
protected RWLock[]	locks
protected long	lockWaitTime
protected static org.slf4j.Logger	log
protected long	mapBase
protected int	maxSamples
protected static long	MB
protected long	minTimeToLive
protected static int	NEXT_OFFSET
protected static int	TIME_OFFSET
protected long	timeToLive
protected static sun.misc.Unsafe	unsafe

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	OffheapMap(int capacity)
protected	OffheapMap(int capacity, long address)

Method Summary

Modifier and Type	Method	Description
protected abstract long	allocateEntry(K key, long hashCode, int size)
protected long	bucketFor(long hashCode)
void	clear()
void	close()
protected void	closeInternal()
private static RWLock[]	createLocks()
private OffheapMap.Record<K,V>	createRecord(K key, long hashCode, RWLock lock)
private OffheapMap.WritableRecord<K,V>	createWritableRecord(K key, long hashCode, RWLock lock, boolean create)
protected abstract void	destroyEntry(long entry)
int	entriesToClean()
protected abstract boolean	equalsAt(long entry, K key)
V	get(K key)
int	getCapacity()
long	getCleanupInterval()
double	getCleanupThreshold()
int	getCount()
long	getExpirations()
long	getLockWaitTime()
int	getMaxSamples()
long	getMinTimeToLive()
long	getTimeToLive()
protected abstract long	hashCode(K key)
protected boolean	isExpired(long entry, boolean touch)
void	iterate(OffheapMap.Visitor<K,V> visitor)
void	iterate(OffheapMap.Visitor<K,V> visitor, int workers)
void	iterate(OffheapMap.Visitor<K,V> visitor, int start, int end, int step)
void	iterate(OffheapMap.WritableVisitor<K,V> visitor)
void	iterate(OffheapMap.WritableVisitor<K,V> visitor, int workers)
void	iterate(OffheapMap.WritableVisitor<K,V> visitor, int start, int end, int step)
protected K	keyAt(long entry)
protected RWLock	lockFor(long hashCode)
OffheapMap.Record<K,V>	lockRecordForRead(K key)
OffheapMap.Record<K,V>	lockRecordForRead(K key, long timeout)
OffheapMap.WritableRecord<K,V>	lockRecordForWrite(K key, boolean create)
OffheapMap.WritableRecord<K,V>	lockRecordForWrite(K key, long timeout, boolean create)
boolean	put(K key, V value)
boolean	putIfAbsent(K key, V value)
boolean	remove(K key)
int	removeExpired(long expirationAge)
protected boolean	reuseEntry(long entry, int newSize)
void	setCleanupInterval(long cleanupInterval)
void	setCleanupThreshold(double cleanupThreshold)
void	setLockWaitTime(long lockWaitTime)
void	setMaxSamples(int maxSamples)
void	setMinTimeToLive(long minTimeToLive)
protected void	setTimeAt(long entry)
protected void	setTimeAt(long entry, long time)
void	setTimeToLive(long timeToLive)
protected abstract void	setValueAt(long entry, V value)
protected boolean	shouldCleanup(long entry, long expirationTime)
protected abstract int	sizeOf(long entry)
protected abstract int	sizeOf(V value)
protected long	timeAt(long entry)
void	touch(K key)
protected abstract V	valueAt(long entry)

Methods inherited from class java.lang.Object

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

Field Detail

log

protected static final org.slf4j.Logger log

unsafe

protected static final sun.misc.Unsafe unsafe

byteArrayOffset

protected static final long byteArrayOffset

MB

protected static final long MB

See Also:

Constant Field Values

CONCURRENCY_LEVEL

protected static final int CONCURRENCY_LEVEL

See Also:

Constant Field Values

HASH_OFFSET

protected static final int HASH_OFFSET

See Also:

Constant Field Values

NEXT_OFFSET

protected static final int NEXT_OFFSET

See Also:

Constant Field Values

TIME_OFFSET

protected static final int TIME_OFFSET

See Also:

Constant Field Values

HEADER_SIZE

protected static final int HEADER_SIZE

See Also:

Constant Field Values

capacity

protected final int capacity

count

protected final java.util.concurrent.atomic.AtomicInteger count

expirations

protected final java.util.concurrent.atomic.AtomicLong expirations

locks

protected final RWLock[] locks

mapBase

protected long mapBase

timeToLive

protected long timeToLive

minTimeToLive

protected long minTimeToLive

lockWaitTime

protected long lockWaitTime

cleanupInterval

protected long cleanupInterval

cleanupThreshold

protected double cleanupThreshold

maxSamples

protected int maxSamples

cleanupThread

protected OffheapMap.BasicCleanup cleanupThread

Constructor Detail

OffheapMap

protected OffheapMap(int capacity)

OffheapMap

protected OffheapMap(int capacity,
                     long address)

Method Detail

createLocks

private static RWLock[] createLocks()

close

public final void close()

closeInternal

protected void closeInternal()

getTimeToLive

public long getTimeToLive()

Specified by:

getTimeToLive in interface OffheapMapMXBean

setTimeToLive

public void setTimeToLive(long timeToLive)

Specified by:

setTimeToLive in interface OffheapMapMXBean

getMinTimeToLive

public long getMinTimeToLive()

Specified by:

getMinTimeToLive in interface OffheapMapMXBean

setMinTimeToLive

public void setMinTimeToLive(long minTimeToLive)

Specified by:

setMinTimeToLive in interface OffheapMapMXBean

getLockWaitTime

public long getLockWaitTime()

Specified by:

getLockWaitTime in interface OffheapMapMXBean

setLockWaitTime

public void setLockWaitTime(long lockWaitTime)

Specified by:

setLockWaitTime in interface OffheapMapMXBean

getCleanupInterval

public long getCleanupInterval()

Specified by:

getCleanupInterval in interface OffheapMapMXBean

setCleanupInterval

public void setCleanupInterval(long cleanupInterval)

Specified by:

setCleanupInterval in interface OffheapMapMXBean

getCleanupThreshold

public double getCleanupThreshold()

Specified by:

getCleanupThreshold in interface OffheapMapMXBean

setCleanupThreshold

public void setCleanupThreshold(double cleanupThreshold)

Specified by:

setCleanupThreshold in interface OffheapMapMXBean

getMaxSamples

public int getMaxSamples()

Specified by:

getMaxSamples in interface OffheapMapMXBean

setMaxSamples

public void setMaxSamples(int maxSamples)

Specified by:

setMaxSamples in interface OffheapMapMXBean

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface OffheapMapMXBean

getCount

public int getCount()

Specified by:

getCount in interface OffheapMapMXBean

getExpirations

public long getExpirations()

Specified by:

getExpirations in interface OffheapMapMXBean

get

public V get(K key)

put

public boolean put(K key,
                   V value)
            throws OutOfMemoryException

Throws:

OutOfMemoryException

putIfAbsent

public boolean putIfAbsent(K key,
                           V value)
                    throws OutOfMemoryException

Throws:

OutOfMemoryException

remove

public boolean remove(K key)

touch

public void touch(K key)

lockRecordForRead

public OffheapMap.Record<K,V> lockRecordForRead(K key,
                                                      long timeout)
                                               throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

lockRecordForRead

public OffheapMap.Record<K,V> lockRecordForRead(K key)

createRecord

private OffheapMap.Record<K,V> createRecord(K key,
                                                  long hashCode,
                                                  RWLock lock)

lockRecordForWrite

public OffheapMap.WritableRecord<K,V> lockRecordForWrite(K key,
                                                               long timeout,
                                                               boolean create)
                                                        throws java.util.concurrent.TimeoutException

Throws:

java.util.concurrent.TimeoutException

lockRecordForWrite

public OffheapMap.WritableRecord<K,V> lockRecordForWrite(K key,
                                                               boolean create)

createWritableRecord

private OffheapMap.WritableRecord<K,V> createWritableRecord(K key,
                                                                  long hashCode,
                                                                  RWLock lock,
                                                                  boolean create)

entriesToClean

public int entriesToClean()

removeExpired

public int removeExpired(long expirationAge)

clear

public void clear()

iterate

public void iterate(OffheapMap.Visitor<K,V> visitor)

iterate

public void iterate(OffheapMap.Visitor<K,V> visitor,
                    int workers)

iterate

public void iterate(OffheapMap.Visitor<K,V> visitor,
                    int start,
                    int end,
                    int step)

iterate

public void iterate(OffheapMap.WritableVisitor<K,V> visitor)

iterate

public void iterate(OffheapMap.WritableVisitor<K,V> visitor,
                    int workers)

iterate

public void iterate(OffheapMap.WritableVisitor<K,V> visitor,
                    int start,
                    int end,
                    int step)

bucketFor

protected long bucketFor(long hashCode)

lockFor

protected RWLock lockFor(long hashCode)

timeAt

protected long timeAt(long entry)

setTimeAt

protected void setTimeAt(long entry)

setTimeAt

protected void setTimeAt(long entry,
                         long time)

isExpired

protected boolean isExpired(long entry,
                            boolean touch)

shouldCleanup

protected boolean shouldCleanup(long entry,
                                long expirationTime)

keyAt

protected K keyAt(long entry)

reuseEntry

protected boolean reuseEntry(long entry,
                             int newSize)

hashCode

protected abstract long hashCode(K key)

equalsAt

protected abstract boolean equalsAt(long entry,
                                    K key)

valueAt

protected abstract V valueAt(long entry)

setValueAt

protected abstract void setValueAt(long entry,
                                   V value)

allocateEntry

protected abstract long allocateEntry(K key,
                                      long hashCode,
                                      int size)
                               throws OutOfMemoryException

Throws:

OutOfMemoryException

destroyEntry

protected abstract void destroyEntry(long entry)

sizeOf

protected abstract int sizeOf(long entry)

sizeOf

protected abstract int sizeOf(V value)