Package org.terracotta.statistics.derived.histogram

Class Striped<T>

java.lang.Object

org.terracotta.statistics.derived.histogram.Striped<T>

Direct Known Subclasses:

StripedHistogram

public class Striped<T>
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	Striped.Cell<T>
(package private) static class	Striped.CellSpliterator<T>

Field Summary

Fields

Modifier and Type	Field	Description
private Striped.Cell<T>	base
private Striped.Cell<T>[]	cells
private java.util.function.Supplier<T>	constructor
private static int	NCPU
private java.util.concurrent.atomic.AtomicInteger	stripeGuard
private static java.lang.ThreadLocal<java.lang.Integer>	threadHash

Constructor Summary

Constructors

Constructor	Description
Striped(java.util.function.Supplier<T> constructor)

Method Summary

Modifier and Type	Method	Description
(package private) static int	advanceProbe(int probe)
protected void	process(java.util.function.Consumer<T> process)
private void	processWithContention(int hash, java.util.function.Consumer<T> process, boolean contended)
protected java.util.stream.Stream<T>	stream()
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

NCPU

private static final int NCPU

threadHash

private static final java.lang.ThreadLocal<java.lang.Integer> threadHash

stripeGuard

private final java.util.concurrent.atomic.AtomicInteger stripeGuard

constructor

private final java.util.function.Supplier<T> constructor

base

private final Striped.Cell<T> base

cells

private volatile Striped.Cell<T>[] cells

Constructor Detail

Striped

public Striped(java.util.function.Supplier<T> constructor)

Method Detail

advanceProbe

static final int advanceProbe(int probe)

stream

protected final java.util.stream.Stream<T> stream()

process

protected final void process(java.util.function.Consumer<T> process)

processWithContention

private void processWithContention(int hash,
                                   java.util.function.Consumer<T> process,
                                   boolean contended)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object