Dependencies
- java/11
- org.slf4j/slf4j-api/1.7.13
Declarations
-
com
-
conversantmedia
-
util
-
collection
-
concurrent
-
AbstractCondition
-
AbstractSpinningCondition
-
AbstractWaitingCondition
-
CACHE_LINE_REFS: int
-
MAX_WAITERS: int
-
WAITER_MASK: long
-
WAIT_TIME: long
-
waitCount: LongAdder
-
waiter: AtomicReferenceArray<Thread>
-
r1: long
-
r2: long
-
r3: long
-
r4: long
-
r5: long
-
r6: long
-
r7: long
-
waitCache: long
-
c1: long
-
c2: long
-
c3: long
-
c4: long
-
c5: long
-
c6: long
-
c7: long
-
c8: long
-
test(): boolean
-
awaitNanos(long): void
-
await(): void
-
signal(): void
-
-
BlockingStack
-
Capacity
-
ConcurrentQueue
-
ConcurrentStack
-
size: int
-
stack: AtomicReferenceArray<Object>
-
stackTop: ContendedAtomicInteger
-
seqLock: SequenceLock
-
stackNotFullCondition: Condition
-
stackNotEmptyCondition: Condition
-
ConcurrentStack(int): void
-
ConcurrentStack(int, SpinPolicy): void
-
push(Object, long, TimeUnit): boolean
-
pushInterruptibly(Object): void
-
contains(Object): boolean
-
push(Object): boolean
-
peek(): Object
-
pop(): Object
-
pop(long, TimeUnit): Object
-
popInterruptibly(): Object
-
size(): int
-
remainingCapacity(): int
-
isEmpty(): boolean
-
clear(): void
-
isFull(): boolean
-
WaitingStackNotFull
-
WaitingStackNotEmpty
-
SpinningStackNotFull
-
SpinningStackNotEmpty
-
StackNotFull
-
StackNotEmpty
-
-
Condition
-
ContendedAtomicInteger
-
ContendedAtomicLong
-
DisruptorBlockingQueue
-
queueNotFullCondition: Condition
-
queueNotEmptyCondition: Condition
-
DisruptorBlockingQueue(int): void
-
DisruptorBlockingQueue(int, SpinPolicy): void
-
DisruptorBlockingQueue(int, Collection<Object>): void
-
offer(Object): boolean
-
poll(): Object
-
remove(Object[]): int
-
remove(): Object
-
element(): Object
-
put(Object): void
-
offer(Object, long, TimeUnit): boolean
-
take(): Object
-
poll(long, TimeUnit): Object
-
clear(): void
-
remainingCapacity(): int
-
drainTo(Collection<Object>): int
-
drainTo(Collection<Object>, int): int
-
toArray(): Object[]
-
toArray(Object[]): Object[]
-
add(Object): boolean
-
remove(Object): boolean
-
containsAll(Collection<Object>): boolean
-
addAll(Collection<Object>): boolean
-
removeAll(Collection<Object>): boolean
-
retainAll(Collection<Object>): boolean
-
iterator(): Iterator<Object>
-
isFull(): boolean
-
RingIter
-
QueueNotFull
-
QueueNotEmpty
-
WaitingQueueNotFull
-
WaitingQueueNotEmpty
-
SpinningQueueNotFull
-
SpinningQueueNotEmpty
-
-
MPMCBlockingQueue
-
queueNotFullCondition: Condition
-
queueNotEmptyCondition: Condition
-
MPMCBlockingQueue(int): void
-
MPMCBlockingQueue(int, SpinPolicy): void
-
MPMCBlockingQueue(int, Collection<Object>): void
-
offer(Object): boolean
-
poll(): Object
-
remove(Object[]): int
-
remove(): Object
-
element(): Object
-
put(Object): void
-
offer(Object, long, TimeUnit): boolean
-
take(): Object
-
poll(long, TimeUnit): Object
-
clear(): void
-
remainingCapacity(): int
-
drainTo(Collection<Object>): int
-
drainTo(Collection<Object>, int): int
-
toArray(): Object[]
-
toArray(Object[]): Object[]
-
add(Object): boolean
-
remove(Object): boolean
-
containsAll(Collection<Object>): boolean
-
addAll(Collection<Object>): boolean
-
removeAll(Collection<Object>): boolean
-
retainAll(Collection<Object>): boolean
-
iterator(): Iterator<Object>
-
isFull(): boolean
-
RingIter
-
QueueNotFull
-
QueueNotEmpty
-
WaitingQueueNotFull
-
WaitingQueueNotEmpty
-
SpinningQueueNotFull
-
SpinningQueueNotEmpty
-
-
MPMCConcurrentQueue
-
MultithreadConcurrentQueue
-
size: int
-
mask: long
-
tail: LongAdder
-
tailCursor: ContendedAtomicLong
-
p1: long
-
p2: long
-
p3: long
-
p4: long
-
p5: long
-
p6: long
-
p7: long
-
tailCache: long
-
a1: long
-
a2: long
-
a3: long
-
a4: long
-
a5: long
-
a6: long
-
a7: long
-
a8: long
-
buffer: Object[]
-
r1: long
-
r2: long
-
r3: long
-
r4: long
-
r5: long
-
r6: long
-
r7: long
-
headCache: long
-
c1: long
-
c2: long
-
c3: long
-
c4: long
-
c5: long
-
c6: long
-
c7: long
-
c8: long
-
head: LongAdder
-
headCursor: ContendedAtomicLong
-
MultithreadConcurrentQueue(int): void
-
offer(Object): boolean
-
poll(): Object
-
peek(): Object
-
remove(Object[]): int
-
size(): int
-
capacity(): int
-
isEmpty(): boolean
-
clear(): void
-
contains(Object): boolean
-
sumToAvoidOptimization(): long
-
-
OptimisticLock
-
PushPullBlockingQueue
-
queueNotFullCondition: Condition
-
queueNotEmptyCondition: Condition
-
PushPullBlockingQueue(int): void
-
PushPullBlockingQueue(int, SpinPolicy): void
-
PushPullBlockingQueue(int, Collection<Object>): void
-
offer(Object): boolean
-
poll(): Object
-
remove(Object[]): int
-
remove(): Object
-
element(): Object
-
put(Object): void
-
offer(Object, long, TimeUnit): boolean
-
take(): Object
-
poll(long, TimeUnit): Object
-
clear(): void
-
remainingCapacity(): int
-
drainTo(Collection<Object>): int
-
drainTo(Collection<Object>, int): int
-
toArray(): Object[]
-
toArray(Object[]): Object[]
-
add(Object): boolean
-
remove(Object): boolean
-
containsAll(Collection<Object>): boolean
-
addAll(Collection<Object>): boolean
-
removeAll(Collection<Object>): boolean
-
retainAll(Collection<Object>): boolean
-
iterator(): Iterator<Object>
-
isFull(): boolean
-
RingIter
-
QueueNotFull
-
QueueNotEmpty
-
WaitingQueueNotFull
-
WaitingQueueNotEmpty
-
SpinningQueueNotFull
-
SpinningQueueNotEmpty
-
-
PushPullConcurrentQueue
-
size: int
-
mask: long
-
tail: LongAdder
-
p1: long
-
p2: long
-
p3: long
-
p4: long
-
p5: long
-
p6: long
-
p7: long
-
tailCache: long
-
a1: long
-
a2: long
-
a3: long
-
a4: long
-
a5: long
-
a6: long
-
a7: long
-
a8: long
-
buffer: Object[]
-
r1: long
-
r2: long
-
r3: long
-
r4: long
-
r5: long
-
r6: long
-
r7: long
-
headCache: long
-
c1: long
-
c2: long
-
c3: long
-
c4: long
-
c5: long
-
c6: long
-
c7: long
-
c8: long
-
head: LongAdder
-
PushPullConcurrentQueue(int): void
-
offer(Object): boolean
-
poll(): Object
-
remove(Object[]): int
-
clear(): void
-
peek(): Object
-
size(): int
-
capacity(): int
-
isEmpty(): boolean
-
contains(Object): boolean
-
sumToAvoidOptimization(): long
-
-
SequenceLock
-
SpinPolicy
-
-
estimation
-
Percentile
-
DEFAULT_PERCENTILE: float[]
-
quantiles: float[]
-
m: int
-
q: float[]
-
n: int[]
-
f: float[]
-
d: float[]
-
e: float[]
-
isInitializing: boolean
-
ni: int
-
Percentile(): void
-
Percentile(float[]): void
-
clear(): void
-
add(float): void
-
getQuantiles(): float[]
-
isReady(): boolean
-
getNSamples(): int
-
getEstimates(): float[]
-
getMin(): float
-
getMax(): float
-
addMeasurement(float): void
-
print(PrintStream, String, Percentile): void
-
InsufficientSamplesException
-
-
PercentileFile
-
-
-
-
Java files
com/conversantmedia/util/
Class files