Index

A B C D E F G H I L M N O P Q R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

a1 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a1 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a1 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
a2 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a2 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a2 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
a3 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a3 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a3 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
a4 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a4 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a4 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
a5 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a5 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a5 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
a6 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a6 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a6 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
a7 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a7 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a7 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
a8 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
a8 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
a8 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
AbstractCondition - Class in com.conversantmedia.util.concurrent
Created by jcairns on 12/11/14.
AbstractCondition() - Constructor for class com.conversantmedia.util.concurrent.AbstractCondition
 
AbstractSpinningCondition - Class in com.conversantmedia.util.concurrent
Created by jcairns on 2/18/16.
AbstractSpinningCondition() - Constructor for class com.conversantmedia.util.concurrent.AbstractSpinningCondition
 
AbstractWaitingCondition - Class in com.conversantmedia.util.concurrent
Created by jcairns on 12/11/14.
AbstractWaitingCondition() - Constructor for class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
add(float) - Method in class com.conversantmedia.util.estimation.Percentile
Add a measurement to estimate
add(E) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
add(E) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
add(E) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
addAll(Collection<? extends E>) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
addAll(Collection<? extends E>) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
addAll(Collection<? extends E>) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
addMeasurement(float) - Method in class com.conversantmedia.util.estimation.Percentile
 
await() - Method in class com.conversantmedia.util.concurrent.AbstractCondition
 
await() - Method in class com.conversantmedia.util.concurrent.AbstractSpinningCondition
 
await() - Method in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
await() - Method in interface com.conversantmedia.util.concurrent.Condition
 
awaitNanos(long) - Method in class com.conversantmedia.util.concurrent.AbstractCondition
 
awaitNanos(long) - Method in class com.conversantmedia.util.concurrent.AbstractSpinningCondition
 
awaitNanos(long) - Method in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
awaitNanos(long) - Method in interface com.conversantmedia.util.concurrent.Condition
 

B

BLOCKING - Enum constant in enum com.conversantmedia.util.concurrent.SpinPolicy
 
BlockingStack<N> - Interface in com.conversantmedia.util.concurrent
Created by jcairns on 2/16/16.
buffer - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
buffer - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
buffer - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 

C

c1 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c1 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c1 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
c2 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c2 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c2 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
c3 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c3 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c3 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
c4 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c4 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c4 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
c5 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c5 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c5 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
c6 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c6 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c6 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
c7 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c7 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c7 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
c8 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
c8 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
c8 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
CACHE_LINE - Static variable in class com.conversantmedia.util.concurrent.ContendedAtomicLong
 
CACHE_LINE_INTS - Static variable in class com.conversantmedia.util.concurrent.ContendedAtomicInteger
 
CACHE_LINE_LONGS - Static variable in class com.conversantmedia.util.concurrent.ContendedAtomicLong
 
CACHE_LINE_REFS - Static variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
capacity() - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
 
capacity() - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
capacity() - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
capacity() - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
Capacity - Class in com.conversantmedia.util.concurrent
Created by jcairns on 7/12/2018
Capacity() - Constructor for class com.conversantmedia.util.concurrent.Capacity
 
Cell(long) - Constructor for class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
clear() - Method in class com.conversantmedia.util.collection.FixedStack
clear the stack
clear() - Method in interface com.conversantmedia.util.collection.Stack
clear the stack
clear() - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
clear the queue of all elements
clear() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
clear the stack - does not null old references
clear() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
clear() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
clear() - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
clear() - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
clear() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
clear() - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
clear() - Method in class com.conversantmedia.util.estimation.Percentile
clear existing samples
com.conversantmedia.util.collection - package com.conversantmedia.util.collection
 
com.conversantmedia.util.concurrent - package com.conversantmedia.util.concurrent
 
com.conversantmedia.util.estimation - package com.conversantmedia.util.estimation
 
compareAndSet(int, int) - Method in class com.conversantmedia.util.concurrent.ContendedAtomicInteger
 
compareAndSet(long, long) - Method in class com.conversantmedia.util.concurrent.ContendedAtomicLong
 
ConcurrentQueue<E> - Interface in com.conversantmedia.util.concurrent
A very high performance blocking buffer, based on Disruptor approach to queues Created by jcairns on 5/28/14.
ConcurrentStack<N> - Class in com.conversantmedia.util.concurrent
Concurrent "lock-free" version of a stack.
ConcurrentStack(int) - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack
 
ConcurrentStack(int, SpinPolicy) - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack
construct a new stack of given capacity
ConcurrentStack.SpinningStackNotEmpty - Class in com.conversantmedia.util.concurrent
 
ConcurrentStack.SpinningStackNotFull - Class in com.conversantmedia.util.concurrent
 
ConcurrentStack.StackNotEmpty - Class in com.conversantmedia.util.concurrent
 
ConcurrentStack.StackNotFull - Class in com.conversantmedia.util.concurrent
 
ConcurrentStack.WaitingStackNotEmpty - Class in com.conversantmedia.util.concurrent
 
ConcurrentStack.WaitingStackNotFull - Class in com.conversantmedia.util.concurrent
 
condition - Variable in class com.conversantmedia.util.concurrent.AbstractCondition
 
Condition - Interface in com.conversantmedia.util.concurrent
 
contains(Object) - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
 
contains(Object) - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
contains(Object) - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
contains(Object) - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
contains(N) - Method in class com.conversantmedia.util.collection.FixedStack
 
contains(N) - Method in interface com.conversantmedia.util.collection.Stack
Linear search the stack for contains - not an efficient operation
contains(N) - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
 
containsAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
containsAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
containsAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
contendedArray - Variable in class com.conversantmedia.util.concurrent.ContendedAtomicInteger
 
contendedArray - Variable in class com.conversantmedia.util.concurrent.ContendedAtomicLong
 
ContendedAtomicInteger - Class in com.conversantmedia.util.concurrent
Avoid false cache line sharing Created by jcairns on 5/28/14.
ContendedAtomicInteger(int) - Constructor for class com.conversantmedia.util.concurrent.ContendedAtomicInteger
 
ContendedAtomicLong - Class in com.conversantmedia.util.concurrent
Avoid false cache line sharing Created by jcairns on 5/28/14.
ContendedAtomicLong(long) - Constructor for class com.conversantmedia.util.concurrent.ContendedAtomicLong
 

D

d - Variable in class com.conversantmedia.util.estimation.Percentile
 
DEFAULT_PERCENTILE - Static variable in class com.conversantmedia.util.estimation.Percentile
 
DisruptorBlockingQueue<E> - Class in com.conversantmedia.util.concurrent
This is a lock free blocking queue that implements a fixed length queue backed by a ring buffer.
DisruptorBlockingQueue(int) - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
Construct a blocking queue of the given fixed capacity.
DisruptorBlockingQueue(int, SpinPolicy) - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
Construct a blocking queue with a given fixed capacity
DisruptorBlockingQueue(int, Collection<? extends E>) - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
Construct a blocking queue of the given fixed capacity
DisruptorBlockingQueue.QueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
DisruptorBlockingQueue.QueueNotFull - Class in com.conversantmedia.util.concurrent
 
DisruptorBlockingQueue.RingIter - Class in com.conversantmedia.util.concurrent
 
DisruptorBlockingQueue.SpinningQueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
DisruptorBlockingQueue.SpinningQueueNotFull - Class in com.conversantmedia.util.concurrent
 
DisruptorBlockingQueue.WaitingQueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
DisruptorBlockingQueue.WaitingQueueNotFull - Class in com.conversantmedia.util.concurrent
 
drainTo(Collection<? super E>) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
drainTo(Collection<? super E>) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
drainTo(Collection<? super E>) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
drainTo(Collection<? super E>, int) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
drainTo(Collection<? super E>, int) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
drainTo(Collection<? super E>, int) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
dx - Variable in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.RingIter
 
dx - Variable in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.RingIter
 
dx - Variable in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.RingIter
 

E

e - Variable in class com.conversantmedia.util.estimation.Percentile
 
element() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
element() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
element() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
entry - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 

F

f - Variable in class com.conversantmedia.util.estimation.Percentile
 
FixedStack<N> - Class in com.conversantmedia.util.collection
A very high performance stack to replace java.util.Stack.
FixedStack(int) - Constructor for class com.conversantmedia.util.collection.FixedStack
construct a new stack of given capacity

G

get() - Method in class com.conversantmedia.util.concurrent.ContendedAtomicInteger
 
get() - Method in class com.conversantmedia.util.concurrent.ContendedAtomicLong
 
getCapacity(int) - Static method in class com.conversantmedia.util.concurrent.Capacity
return the next power of two after @param capacity or capacity if it is already
getEstimates() - Method in class com.conversantmedia.util.estimation.Percentile
get the estimates based on the last sample
getMax() - Method in class com.conversantmedia.util.estimation.Percentile
 
getMin() - Method in class com.conversantmedia.util.estimation.Percentile
 
getNSamples() - Method in class com.conversantmedia.util.estimation.Percentile
 
getQuantiles() - Method in class com.conversantmedia.util.estimation.Percentile
 

H

hasNext() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.RingIter
 
hasNext() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.RingIter
 
hasNext() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.RingIter
 
head - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
head - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
head - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
headCache - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
headCache - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
headCursor - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 

I

InsufficientSamplesException() - Constructor for exception class com.conversantmedia.util.estimation.Percentile.InsufficientSamplesException
 
isEmpty() - Method in class com.conversantmedia.util.collection.FixedStack
 
isEmpty() - Method in interface com.conversantmedia.util.collection.Stack
 
isEmpty() - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
 
isEmpty() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
 
isEmpty() - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
isEmpty() - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
isEmpty() - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
isFull() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
 
isFull() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
isFull() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
isFull() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
isInitializing - Variable in class com.conversantmedia.util.estimation.Percentile
 
isPowerOf2(int) - Static method in class com.conversantmedia.util.concurrent.Capacity
 
isReady() - Method in class com.conversantmedia.util.estimation.Percentile
 
iterator() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
iterator() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
iterator() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 

L

lastObj - Variable in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.RingIter
 
lastObj - Variable in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.RingIter
 
lastObj - Variable in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.RingIter
 

M

m - Variable in class com.conversantmedia.util.estimation.Percentile
 
main(String[]) - Static method in class com.conversantmedia.util.estimation.PercentileFile
 
mask - Variable in class com.conversantmedia.util.collection.FixedStack
 
mask - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
mask - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
mask - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
MAX_POWER2 - Static variable in class com.conversantmedia.util.concurrent.Capacity
 
MAX_PROG_YIELD - Static variable in interface com.conversantmedia.util.concurrent.Condition
 
MAX_WAITERS - Static variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
MPMCBlockingQueue<E> - Class in com.conversantmedia.util.concurrent
Alternative implementation for benchmarking purposes
MPMCBlockingQueue(int) - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue
Construct a blocking queue of the given fixed capacity.
MPMCBlockingQueue(int, SpinPolicy) - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue
Construct a blocking queue with a given fixed capacity
MPMCBlockingQueue(int, Collection<? extends E>) - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue
Construct a blocking queue of the given fixed capacity
MPMCBlockingQueue.QueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
MPMCBlockingQueue.QueueNotFull - Class in com.conversantmedia.util.concurrent
 
MPMCBlockingQueue.RingIter - Class in com.conversantmedia.util.concurrent
 
MPMCBlockingQueue.SpinningQueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
MPMCBlockingQueue.SpinningQueueNotFull - Class in com.conversantmedia.util.concurrent
 
MPMCBlockingQueue.WaitingQueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
MPMCBlockingQueue.WaitingQueueNotFull - Class in com.conversantmedia.util.concurrent
 
MPMCConcurrentQueue<E> - Class in com.conversantmedia.util.concurrent
Dmitry Vyukov, Bounded MPMC queue - http://www.1024cores.net/home/lock-free-algorithms/queues/bounded-mpmc-queue Added for benchmarking and comparison.
MPMCConcurrentQueue(int) - Constructor for class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
Construct a blocking queue of the given fixed capacity.
MPMCConcurrentQueue.Cell<R> - Class in com.conversantmedia.util.concurrent
 
MultithreadConcurrentQueue<E> - Class in com.conversantmedia.util.concurrent
This is the disruptor implemented for multiple simultaneous reader and writer threads.
MultithreadConcurrentQueue(int) - Constructor for class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
Construct a blocking queue of the given fixed capacity.

N

n - Variable in class com.conversantmedia.util.estimation.Percentile
 
next() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.RingIter
 
next() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.RingIter
 
next() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.RingIter
 
ni - Variable in class com.conversantmedia.util.estimation.Percentile
 

O

offer(E) - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
Add element t to the ring
offer(E) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
offer(E) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
offer(E) - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
offer(E) - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
offer(E) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
offer(E) - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
offer(E, long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
offer(E, long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
offer(E, long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
onSpinWait() - Static method in interface com.conversantmedia.util.concurrent.Condition
 
OptimisticLock - Interface in com.conversantmedia.util.concurrent
Created by jcairns on 2/12/16.

P

p1 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
p1 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
p1 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
p2 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
p2 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
p2 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
p3 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
p3 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
p3 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
p4 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
p4 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
p4 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
p5 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
p5 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
p5 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
p6 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
p6 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
p6 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
p7 - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
p7 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
p7 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
PARK_TIMEOUT - Static variable in interface com.conversantmedia.util.concurrent.Condition
 
peek() - Method in class com.conversantmedia.util.collection.FixedStack
peek at the top of the stack
peek() - Method in interface com.conversantmedia.util.collection.Stack
show the current stack top
peek() - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
return the first element in the queue
peek() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
peek at the top of the stack
peek() - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
peek() - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
peek() - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
Percentile - Class in com.conversantmedia.util.estimation
Implementation of "Simulatenous Estimation of Several Persentiles," by Kimmo E.
Percentile() - Constructor for class com.conversantmedia.util.estimation.Percentile
 
Percentile(float[]) - Constructor for class com.conversantmedia.util.estimation.Percentile
 
Percentile.InsufficientSamplesException - Exception Class in com.conversantmedia.util.estimation
Indicates too few measurements have been added to compute the requested estimation
PercentileFile - Class in com.conversantmedia.util.estimation
Created by jcairns on 3/4/15.
PercentileFile() - Constructor for class com.conversantmedia.util.estimation.PercentileFile
 
poll() - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
remove the first element from the queue and return it
poll() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
poll() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
poll() - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
poll() - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
poll() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
poll() - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
poll(long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
poll(long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
poll(long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
pop() - Method in class com.conversantmedia.util.collection.FixedStack
pop the next element off the stack
pop() - Method in interface com.conversantmedia.util.collection.Stack
pop and return the element from the top of the stack
pop() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
pop the next element off the stack
pop(long, TimeUnit) - Method in interface com.conversantmedia.util.concurrent.BlockingStack
Pop an element from the stack, waiting if necessary if the stack is currently empty
pop(long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
 
popInterruptibly() - Method in interface com.conversantmedia.util.concurrent.BlockingStack
Pop an element from the stack, waiting as long as required for an element to become available on the stack
popInterruptibly() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
 
print(PrintStream, String, Percentile) - Static method in class com.conversantmedia.util.estimation.Percentile
print a nice histogram of percentiles
progressiveYield(int) - Static method in interface com.conversantmedia.util.concurrent.Condition
 
push(N) - Method in class com.conversantmedia.util.collection.FixedStack
add an element to the stack
push(N) - Method in interface com.conversantmedia.util.collection.Stack
Add the element to the stack top, optionally failing if there is no capacity (overflow)
push(N) - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
add an element to the stack, failing if the stack is unable to grow
push(N, long, TimeUnit) - Method in interface com.conversantmedia.util.concurrent.BlockingStack
Push an element on the stack, waiting if necessary if the stack is currently full
push(N, long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
 
pushInterruptibly(N) - Method in interface com.conversantmedia.util.concurrent.BlockingStack
Push an element on the stack waiting as long as required for space to become available
pushInterruptibly(N) - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
 
PushPullBlockingQueue<E> - Class in com.conversantmedia.util.concurrent
Single thread implementation of disruptor
PushPullBlockingQueue(int) - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue
Construct a blocking queue of the given fixed capacity.
PushPullBlockingQueue(int, SpinPolicy) - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue
Construct a blocking queue with a given fixed capacity
PushPullBlockingQueue(int, Collection<? extends E>) - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue
Construct a blocking queue of the given fixed capacity
PushPullBlockingQueue.QueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
PushPullBlockingQueue.QueueNotFull - Class in com.conversantmedia.util.concurrent
 
PushPullBlockingQueue.RingIter - Class in com.conversantmedia.util.concurrent
 
PushPullBlockingQueue.SpinningQueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
PushPullBlockingQueue.SpinningQueueNotFull - Class in com.conversantmedia.util.concurrent
 
PushPullBlockingQueue.WaitingQueueNotEmpty - Class in com.conversantmedia.util.concurrent
 
PushPullBlockingQueue.WaitingQueueNotFull - Class in com.conversantmedia.util.concurrent
 
PushPullConcurrentQueue<E> - Class in com.conversantmedia.util.concurrent
Tuned version of Martin Thompson's push pull queue Transfers from a single thread writer to a single thread reader are orders of nanoseconds (3-5) This code is optimized and tested using a 64bit HotSpot JVM on an Intel x86-64 environment.
PushPullConcurrentQueue(int) - Constructor for class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
put(E) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
put(E) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
put(E) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 

Q

q - Variable in class com.conversantmedia.util.estimation.Percentile
 
quantiles - Variable in class com.conversantmedia.util.estimation.Percentile
 
queueLock - Variable in class com.conversantmedia.util.concurrent.AbstractCondition
 
QueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.QueueNotEmpty
 
QueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue.QueueNotEmpty
 
QueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue.QueueNotEmpty
 
queueNotEmptyCondition - Variable in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
queueNotEmptyCondition - Variable in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
queueNotEmptyCondition - Variable in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
QueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.QueueNotFull
 
QueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue.QueueNotFull
 
QueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue.QueueNotFull
 
queueNotFullCondition - Variable in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
queueNotFullCondition - Variable in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
queueNotFullCondition - Variable in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 

R

r1 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
r1 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
r1 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
r2 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
r2 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
r2 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
r3 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
r3 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
r3 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
r4 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
r4 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
r4 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
r5 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
r5 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
r5 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
r6 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
r6 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
r6 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
r7 - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
r7 - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
r7 - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
readLock() - Method in interface com.conversantmedia.util.concurrent.OptimisticLock
Aquire a lock token for reading
readLock() - Method in class com.conversantmedia.util.concurrent.SequenceLock
 
readLockHeld(long) - Method in interface com.conversantmedia.util.concurrent.OptimisticLock
check if optimistic locking succeeded
readLockHeld(long) - Method in class com.conversantmedia.util.concurrent.SequenceLock
 
remainingCapacity() - Method in class com.conversantmedia.util.collection.FixedStack
how much available space in the stack
remainingCapacity() - Method in interface com.conversantmedia.util.collection.Stack
 
remainingCapacity() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
how much available space in the stack
remainingCapacity() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
remainingCapacity() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
remainingCapacity() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
remove() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
remove() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.RingIter
 
remove() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
remove() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.RingIter
 
remove() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
remove() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.RingIter
 
remove(E[]) - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
return all elements in the queue to the provided array, up to the size of the provided array.
remove(E[]) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
remove(E[]) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
remove(E[]) - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
remove(E[]) - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
remove(E[]) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
remove(E[]) - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
remove(Object) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
Provided for compatibility with the BlockingQueue interface only.
remove(Object) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
remove(Object) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
removeAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
removeAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
removeAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
retainAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
retainAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
retainAll(Collection<?>) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
RingIter() - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.RingIter
 
RingIter() - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue.RingIter
 
RingIter() - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue.RingIter
 

S

seq - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
seqLock - Variable in class com.conversantmedia.util.concurrent.ConcurrentStack
 
sequence - Variable in class com.conversantmedia.util.concurrent.SequenceLock
 
SequenceLock - Class in com.conversantmedia.util.concurrent
http://www.hpl.hp.com/techreports/2012/HPL-2012-68.pdf Created by jcairns on 2/12/16.
SequenceLock() - Constructor for class com.conversantmedia.util.concurrent.SequenceLock
 
set(int) - Method in class com.conversantmedia.util.concurrent.ContendedAtomicInteger
 
set(long) - Method in class com.conversantmedia.util.concurrent.ContendedAtomicLong
 
signal() - Method in class com.conversantmedia.util.concurrent.AbstractCondition
 
signal() - Method in class com.conversantmedia.util.concurrent.AbstractSpinningCondition
 
signal() - Method in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
signal() - Method in interface com.conversantmedia.util.concurrent.Condition
 
size - Variable in class com.conversantmedia.util.collection.FixedStack
 
size - Variable in class com.conversantmedia.util.concurrent.ConcurrentStack
 
size - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
size - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
size - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
size() - Method in class com.conversantmedia.util.collection.FixedStack
Return the size of the stack
size() - Method in interface com.conversantmedia.util.collection.Stack
 
size() - Method in interface com.conversantmedia.util.concurrent.ConcurrentQueue
 
size() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack
Return the size of the stack
size() - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
size() - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
This implemention is known to be broken if preemption were to occur after reading the tail pointer.
size() - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
This implemention is known to be broken if preemption were to occur after reading the tail pointer.
SPINNING - Enum constant in enum com.conversantmedia.util.concurrent.SpinPolicy
 
SpinningQueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.SpinningQueueNotEmpty
 
SpinningQueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue.SpinningQueueNotEmpty
 
SpinningQueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue.SpinningQueueNotEmpty
 
SpinningQueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.SpinningQueueNotFull
 
SpinningQueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue.SpinningQueueNotFull
 
SpinningQueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue.SpinningQueueNotFull
 
SpinningStackNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack.SpinningStackNotEmpty
 
SpinningStackNotFull() - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack.SpinningStackNotFull
 
SpinPolicy - Enum in com.conversantmedia.util.concurrent
Three SpinPolicy values are supported.
SpinPolicy() - Constructor for enum com.conversantmedia.util.concurrent.SpinPolicy
 
stack - Variable in class com.conversantmedia.util.collection.FixedStack
 
stack - Variable in class com.conversantmedia.util.concurrent.ConcurrentStack
 
Stack<N> - Interface in com.conversantmedia.util.collection
Created by jcairns on 6/11/14.
StackNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack.StackNotEmpty
 
stackNotEmptyCondition - Variable in class com.conversantmedia.util.concurrent.ConcurrentStack
 
StackNotFull() - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack.StackNotFull
 
stackNotFullCondition - Variable in class com.conversantmedia.util.concurrent.ConcurrentStack
 
stackTop - Variable in class com.conversantmedia.util.collection.FixedStack
 
stackTop - Variable in class com.conversantmedia.util.concurrent.ConcurrentStack
 
sumToAvoidOptimization() - Method in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue.Cell
 
sumToAvoidOptimization() - Method in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
sumToAvoidOptimization() - Method in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 

T

tail - Variable in class com.conversantmedia.util.concurrent.MPMCConcurrentQueue
 
tail - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
tail - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
tailCache - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
tailCache - Variable in class com.conversantmedia.util.concurrent.PushPullConcurrentQueue
 
tailCursor - Variable in class com.conversantmedia.util.concurrent.MultithreadConcurrentQueue
 
take() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
take() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
take() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
test() - Method in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
code below will block until test() returns false
test() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack.SpinningStackNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack.SpinningStackNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack.StackNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack.StackNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack.WaitingStackNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.ConcurrentStack.WaitingStackNotFull
 
test() - Method in interface com.conversantmedia.util.concurrent.Condition
 
test() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.QueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.QueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.SpinningQueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.SpinningQueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.WaitingQueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.WaitingQueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.QueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.QueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.SpinningQueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.SpinningQueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.WaitingQueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue.WaitingQueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.QueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.QueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.SpinningQueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.SpinningQueueNotFull
 
test() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.WaitingQueueNotEmpty
 
test() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue.WaitingQueueNotFull
 
toArray() - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
toArray() - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
toArray() - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
toArray(T[]) - Method in class com.conversantmedia.util.concurrent.DisruptorBlockingQueue
 
toArray(T[]) - Method in class com.conversantmedia.util.concurrent.MPMCBlockingQueue
 
toArray(T[]) - Method in class com.conversantmedia.util.concurrent.PushPullBlockingQueue
 
toString() - Method in class com.conversantmedia.util.concurrent.ContendedAtomicInteger
 
toString() - Method in class com.conversantmedia.util.concurrent.ContendedAtomicLong
 
tryWriteLock() - Method in interface com.conversantmedia.util.concurrent.OptimisticLock
 
tryWriteLock() - Method in class com.conversantmedia.util.concurrent.SequenceLock
 
tryWriteLock(long, TimeUnit) - Method in interface com.conversantmedia.util.concurrent.OptimisticLock
 
tryWriteLock(long, TimeUnit) - Method in class com.conversantmedia.util.concurrent.SequenceLock
 
tryWriteLockInterruptibly() - Method in interface com.conversantmedia.util.concurrent.OptimisticLock
 
tryWriteLockInterruptibly() - Method in class com.conversantmedia.util.concurrent.SequenceLock
 

U

unlock(long) - Method in interface com.conversantmedia.util.concurrent.OptimisticLock
"commit" or unlock the sequence when the write lock is held
unlock(long) - Method in class com.conversantmedia.util.concurrent.SequenceLock
 

V

valueOf(String) - Static method in enum com.conversantmedia.util.concurrent.SpinPolicy
Returns the enum constant of this type with the specified name.
values() - Static method in enum com.conversantmedia.util.concurrent.SpinPolicy
Returns an array containing the constants of this enum type, in the order they are declared.

W

WAIT_TIME - Static variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
waitCache - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
waitCount - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
waiter - Variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
WAITER_MASK - Static variable in class com.conversantmedia.util.concurrent.AbstractWaitingCondition
 
WAITING - Enum constant in enum com.conversantmedia.util.concurrent.SpinPolicy
 
WaitingQueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.WaitingQueueNotEmpty
 
WaitingQueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue.WaitingQueueNotEmpty
 
WaitingQueueNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue.WaitingQueueNotEmpty
 
WaitingQueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.DisruptorBlockingQueue.WaitingQueueNotFull
 
WaitingQueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.MPMCBlockingQueue.WaitingQueueNotFull
 
WaitingQueueNotFull() - Constructor for class com.conversantmedia.util.concurrent.PushPullBlockingQueue.WaitingQueueNotFull
 
WaitingStackNotEmpty() - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack.WaitingStackNotEmpty
 
WaitingStackNotFull() - Constructor for class com.conversantmedia.util.concurrent.ConcurrentStack.WaitingStackNotFull
 
waitStatus(long, TimeUnit, Condition) - Static method in interface com.conversantmedia.util.concurrent.Condition
Wait for timeout on condition
writeLock() - Method in interface com.conversantmedia.util.concurrent.OptimisticLock
Acquire the lock for writing, waiting if needed
writeLock() - Method in class com.conversantmedia.util.concurrent.SequenceLock
 
A B C D E F G H I L M N O P Q R S T U V W 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form