Skip navigation links
A C D E G I L O P R S T 

A

AbstractOfferable<E> - Class in lbmq
This class provides skeletal implementations of some Offerable operations.
AbstractOfferable() - Constructor for class lbmq.AbstractOfferable
 
AbstractPollable<E> - Class in lbmq
This class provides skeletal implementations of some Pollable operations.
AbstractPollable() - Constructor for class lbmq.AbstractPollable
 
add(E) - Method in class lbmq.AbstractOfferable
 
add(E) - Method in interface lbmq.Offerable
Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions, returning true upon success and throwing an IllegalStateException if no space is currently available.
addAll(Collection<? extends E>) - Method in class lbmq.AbstractOfferable
Adds all of the elements in the specified collection to this queue.
addSubQueue(K, int) - Method in class lbmq.LinkedBlockingMultiQueue
Add a sub queue if absent
addSubQueue(K, int, int) - Method in class lbmq.LinkedBlockingMultiQueue
Add a sub-queue if absent

C

clear() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
Atomically removes all of the elements from this queue.
contains(Object) - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 

D

drainTo(Collection<? super E>) - Method in class lbmq.LinkedBlockingMultiQueue
 
drainTo(Collection<? super E>, int) - Method in class lbmq.LinkedBlockingMultiQueue
 
drainTo(Collection<? super E>) - Method in interface lbmq.Pollable
Removes all available elements from this queue and adds them to the given collection.
drainTo(Collection<? super E>, int) - Method in interface lbmq.Pollable
Removes at most the given number of available elements from this queue and adds them to the given collection.

E

element() - Method in class lbmq.AbstractPollable
Retrieves, but does not remove, the head of this queue.
element() - Method in interface lbmq.Pollable
Retrieves, but does not remove, the head of this queue.
enable(boolean) - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
Enable or disable this sub-queue.

G

getPriorityGroupsCount() - Method in class lbmq.LinkedBlockingMultiQueue
Counts the priority groups currently registered in LinkedBlockingMultiQueue.
getSubQueue(K) - Method in class lbmq.LinkedBlockingMultiQueue
Gets a sub-queue

I

isEmpty() - Method in class lbmq.LinkedBlockingMultiQueue
Returns whether this multi-queue is empty, that is, whether there is any element ready to be taken from the head.
isEmpty() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
Return whether the queue is empty.
isEnabled() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
Returns whether this sub-queue is enabled
iterator() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
Returns an iterator over the elements in this queue in proper sequence.

L

lbmq - package lbmq
"lbmq" is short for "Linked Blocking Multi Queue", which is a concurrent queue that complements the ones offered in the standard package java.util.concurrent
LinkedBlockingMultiQueue<K,E> - Class in lbmq
An optionally-bounded blocking "multi-queue" based on linked nodes.
LinkedBlockingMultiQueue() - Constructor for class lbmq.LinkedBlockingMultiQueue
 
LinkedBlockingMultiQueue.SubQueue - Class in lbmq
Represent a sub-queue inside a multi-queue.

O

offer(E, long, TimeUnit) - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
offer(E) - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
offer(E) - Method in interface lbmq.Offerable
Inserts the specified element into this queue if it is possible to do so immediately without violating capacity restrictions.
offer(E, long, TimeUnit) - Method in interface lbmq.Offerable
Inserts the specified element into this queue, waiting up to the specified wait time if necessary for space to become available.
Offerable<E> - Interface in lbmq
This trait captures the "tail side" of the BlockingQueue interface.

P

peek() - Method in class lbmq.LinkedBlockingMultiQueue
 
peek() - Method in interface lbmq.Pollable
Retrieves, but does not remove, the head of this queue, or returns null if this queue is empty.
poll(long, TimeUnit) - Method in class lbmq.LinkedBlockingMultiQueue
 
poll() - Method in class lbmq.LinkedBlockingMultiQueue
 
poll() - Method in interface lbmq.Pollable
Retrieves and removes the head of this queue, or returns null if this queue is empty.
poll(long, TimeUnit) - Method in interface lbmq.Pollable
Retrieves and removes the head of this queue, waiting up to the specified wait time if necessary for an element to become available.
Pollable<E> - Interface in lbmq
This interface captures the "head side" of the BlockingQueue interface
put(E) - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
put(E) - Method in interface lbmq.Offerable
Inserts the specified element into this queue, waiting if necessary for space to become available.

R

remainingCapacity() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
remainingCapacity() - Method in interface lbmq.Offerable
Returns the number of additional elements that this queue can ideally (in the absence of memory or resource constraints) accept without blocking, or Integer.MAX_VALUE if there is no intrinsic limit.
remove() - Method in class lbmq.AbstractPollable
Retrieves and removes the head of this queue.
remove(Object) - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
remove() - Method in interface lbmq.Pollable
Retrieves and removes the head of this queue.
removeSubQueue(K) - Method in class lbmq.LinkedBlockingMultiQueue
Remove a sub-queue

S

size() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
Return the number of elements in this sub queue.

T

take() - Method in class lbmq.LinkedBlockingMultiQueue
 
take() - Method in interface lbmq.Pollable
Retrieves and removes the head of this queue, waiting if necessary until an element becomes available.
toArray() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
toArray(T[]) - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
toString() - Method in class lbmq.LinkedBlockingMultiQueue.SubQueue
 
totalSize() - Method in class lbmq.LinkedBlockingMultiQueue
Returns the total size of this multi-queue, that is, the sum of the sizes of all the enabled sub-queues.
A C D E G I L O P R S T 
Skip navigation links