org.eclipse.jetty.util

Class ConcurrentArrayBlockingQueue.Unbounded<E>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractQueue<T>

org.eclipse.jetty.util.ConcurrentArrayQueue<E>

org.eclipse.jetty.util.ConcurrentArrayBlockingQueue<E>

org.eclipse.jetty.util.ConcurrentArrayBlockingQueue.Unbounded<E>

Type Parameters:

E -

All Implemented Interfaces:

Iterable<E>, Collection<E>, BlockingQueue<E>, Queue<E>

Enclosing class:

ConcurrentArrayBlockingQueue<E>

public static class ConcurrentArrayBlockingQueue.Unbounded<E>
extends ConcurrentArrayBlockingQueue<E>

An unbounded, blocking version of ConcurrentArrayQueue.

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.util.ConcurrentArrayBlockingQueue

ConcurrentArrayBlockingQueue.Bounded<E>, ConcurrentArrayBlockingQueue.Unbounded<E>

Nested classes/interfaces inherited from class org.eclipse.jetty.util.ConcurrentArrayQueue

ConcurrentArrayQueue.Block<E>

Field Summary

Fields inherited from class org.eclipse.jetty.util.ConcurrentArrayQueue

DEFAULT_BLOCK_SIZE, REMOVED_ELEMENT

Constructor Summary

Constructors

Constructor and Description
Unbounded()
Unbounded(int blockSize)

Method Summary

Modifier and Type	Method and Description
protected int	decrementAndGetSize()
boolean	offer(E item)
boolean	offer(E element, long timeout, TimeUnit unit)
void	put(E element)
int	remainingCapacity()
int	size()

Methods inherited from class org.eclipse.jetty.util.ConcurrentArrayBlockingQueue

drainTo, drainTo, poll, poll, remove, signalConsumer, take

Methods inherited from class org.eclipse.jetty.util.ConcurrentArrayQueue

casHeadBlock, casTailBlock, getBlockCount, getBlockSize, getHeadBlock, getTailBlock, iterator, newBlock, peek, removeAll, retainAll

Methods inherited from class java.util.AbstractQueue

add, addAll, clear, element, remove

Methods inherited from class java.util.AbstractCollection

contains, containsAll, isEmpty, toArray, toArray, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add, contains

Methods inherited from interface java.util.Queue

element, peek, remove

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, iterator, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Constructor Detail

Unbounded

public Unbounded()

Unbounded

public Unbounded(int blockSize)

Method Detail

offer

public boolean offer(E item)

Specified by:

offer in interface BlockingQueue<E>

Specified by:

offer in interface Queue<E>

Overrides:

offer in class ConcurrentArrayQueue<E>

decrementAndGetSize

protected int decrementAndGetSize()

Specified by:

decrementAndGetSize in class ConcurrentArrayBlockingQueue<E>

size

public int size()

Specified by:

size in interface Collection<E>

Overrides:

size in class ConcurrentArrayQueue<E>

remainingCapacity

public int remainingCapacity()

put

public void put(E element)
         throws InterruptedException

Throws:

InterruptedException

offer

public boolean offer(E element,
                     long timeout,
                     TimeUnit unit)
              throws InterruptedException

Throws:

InterruptedException