Package org.HdrHistogram.packedarray

Class ConcurrentPackedLongArray

java.lang.Object

org.HdrHistogram.packedarray.AbstractPackedLongArray

org.HdrHistogram.packedarray.PackedLongArray

org.HdrHistogram.packedarray.ConcurrentPackedLongArray

All Implemented Interfaces:

Serializable, Iterable<Long>

Direct Known Subclasses:

PackedArrayRecorder.InternalConcurrentPackedLongArray

public class ConcurrentPackedLongArray
extends PackedLongArray

A Packed array of signed 64 bit values that supports get(), set(), add() and increment() operations the logical contents of the array.

ConcurrentPackedLongArray supports concurrent accumulation, with the add() and increment() methods providing lossless atomic accumulation in the presence of multiple writers. However, it is important to note that add() and increment() are the *only* safe concurrent operations, and that all other operations, including get(), set() and clear() may produce "surprising" results if used on an array that is not at rest.

While the add() and increment() methods are not quite wait-free, they come "close" that behavior in the sense that a given thread will incur a total of no more than a capped fixed number (e.g. 74 in a current implementation) of non-wait-free add or increment operations during the lifetime of an array, regardless of the number of operations done.

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.HdrHistogram.packedarray.AbstractPackedLongArray

AbstractPackedLongArray.AllValuesIterator

Field Summary

Fields

Modifier and Type	Field	Description
(package private) WriterReaderPhaser	wrp

Fields inherited from class org.HdrHistogram.packedarray.AbstractPackedLongArray

NUMBER_OF_NON_ZEROS_TO_HASH

Constructor Summary

Constructors

Constructor	Description
ConcurrentPackedLongArray(int virtualLength)
ConcurrentPackedLongArray(int virtualLength, int initialPhysicalLength)

Method Summary

Modifier and Type	Method	Description
void	clear()	Clear the array contents
(package private) void	clearContents()
ConcurrentPackedLongArray	copy()	Create a copy of this array, complete with data and everything.
(package private) long	criticalSectionEnter()
(package private) void	criticalSectionExit(long criticalValueAtEnter)
private void	readObject(ObjectInputStream o)
(package private) void	resizeStorageArray(int newPhysicalLengthInLongs)
void	setVirtualLength(int newVirtualArrayLength)	Set a new virtual length for the array.
String	toString()

Methods inherited from class org.HdrHistogram.packedarray.AbstractPackedLongArray

add, add, equals, get, getArrayContext, getEndTimeStamp, getPhysicalLength, getStartTimeStamp, hashCode, increment, iterator, length, nonZeroValues, set, setArrayContext, setEndTimeStamp, setStartTimeStamp

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

wrp

transient WriterReaderPhaser wrp

Constructor Details

ConcurrentPackedLongArray

public ConcurrentPackedLongArray(int virtualLength)

ConcurrentPackedLongArray

public ConcurrentPackedLongArray(int virtualLength,
 int initialPhysicalLength)

Method Details

resizeStorageArray

void resizeStorageArray(int newPhysicalLengthInLongs)

Overrides:

resizeStorageArray in class PackedLongArray

setVirtualLength

public void setVirtualLength(int newVirtualArrayLength)

Description copied from class: AbstractPackedLongArray

Set a new virtual length for the array.

Overrides:

setVirtualLength in class PackedLongArray

Parameters:

newVirtualArrayLength - the

copy

public ConcurrentPackedLongArray copy()

Description copied from class: AbstractPackedLongArray

Create a copy of this array, complete with data and everything.

Overrides:

copy in class PackedLongArray

Returns:

A distinct copy of this array.

clearContents

void clearContents()

Overrides:

clearContents in class PackedLongArray

criticalSectionEnter

long criticalSectionEnter()

Overrides:

criticalSectionEnter in class PackedLongArray

criticalSectionExit

void criticalSectionExit(long criticalValueAtEnter)

Overrides:

criticalSectionExit in class PackedLongArray

toString

public String toString()

Overrides:

toString in class AbstractPackedLongArray

clear

public void clear()

Description copied from class: AbstractPackedLongArray

Clear the array contents

Overrides:

clear in class AbstractPackedLongArray

readObject

private void readObject(ObjectInputStream o)
                 throws IOException,
ClassNotFoundException

Throws:

IOException

ClassNotFoundException