A B C D E F G H I L M N O P Q R S T U V W
All Classes All Packages
All Classes All Packages
All Classes All Packages
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 - 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 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 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 - 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 - 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
All Classes All Packages