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