E
- Type of element in the queuepublic class MultiLockFairBlockingQueue<E> extends Object implements BlockingQueue<E>
BlockingQueue
are implemented.Modifier and Type | Class and Description |
---|---|
protected class |
MultiLockFairBlockingQueue.ExchangeCountDownLatch<T> |
protected class |
MultiLockFairBlockingQueue.FairIterator |
protected class |
MultiLockFairBlockingQueue.ItemFuture<T> |
Constructor and Description |
---|
MultiLockFairBlockingQueue()
Creates a new fair blocking queue.
|
Modifier and Type | Method and Description |
---|---|
boolean |
add(E e) |
boolean |
addAll(Collection<? extends E> c) |
void |
clear() |
boolean |
contains(Object e) |
boolean |
containsAll(Collection<?> c) |
int |
drainTo(Collection<? super E> c) |
int |
drainTo(Collection<? super E> c,
int maxElements) |
E |
element() |
int |
getNextPoll() |
int |
getNextPut() |
boolean |
isEmpty() |
Iterator<E> |
iterator() |
boolean |
offer(E e)
Will always return true, queue is unbounded.
|
boolean |
offer(E e,
long timeout,
TimeUnit unit)
Will never timeout, as it invokes the
offer(Object) method. |
E |
peek() |
E |
poll() |
E |
poll(long timeout,
TimeUnit unit)
Fair retrieval of an object in the queue.
|
Future<E> |
pollAsync()
Request an item from the queue asynchronously
|
void |
put(E e) |
int |
remainingCapacity() |
E |
remove() |
boolean |
remove(Object e) |
boolean |
removeAll(Collection<?> c) |
boolean |
retainAll(Collection<?> c) |
int |
size() |
E |
take() |
Object[] |
toArray() |
<T> T[] |
toArray(T[] a) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
equals, hashCode, parallelStream, removeIf, spliterator, stream
public MultiLockFairBlockingQueue()
public int getNextPut()
public int getNextPoll()
public boolean offer(E e)
public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException
offer(Object)
method.
Once a lock has been acquired, the
offer
in interface BlockingQueue<E>
InterruptedException
public E poll(long timeout, TimeUnit unit) throws InterruptedException
poll
in interface BlockingQueue<E>
InterruptedException
public Future<E> pollAsync()
public boolean remove(Object e)
remove
in interface Collection<E>
remove
in interface BlockingQueue<E>
public int size()
size
in interface Collection<E>
public boolean contains(Object e)
contains
in interface Collection<E>
contains
in interface BlockingQueue<E>
public boolean add(E e)
add
in interface Collection<E>
add
in interface BlockingQueue<E>
add
in interface Queue<E>
public int drainTo(Collection<? super E> c, int maxElements)
drainTo
in interface BlockingQueue<E>
UnsupportedOperationException
- - this operation is not supportedpublic int drainTo(Collection<? super E> c)
drainTo
in interface BlockingQueue<E>
UnsupportedOperationException
- - this operation is not supportedpublic void put(E e) throws InterruptedException
put
in interface BlockingQueue<E>
InterruptedException
public int remainingCapacity()
remainingCapacity
in interface BlockingQueue<E>
public E take() throws InterruptedException
take
in interface BlockingQueue<E>
InterruptedException
public boolean addAll(Collection<? extends E> c)
addAll
in interface Collection<E>
public void clear()
clear
in interface Collection<E>
UnsupportedOperationException
- - this operation is not supportedpublic boolean containsAll(Collection<?> c)
containsAll
in interface Collection<E>
UnsupportedOperationException
- - this operation is not supportedpublic boolean isEmpty()
isEmpty
in interface Collection<E>
public boolean removeAll(Collection<?> c)
removeAll
in interface Collection<E>
UnsupportedOperationException
- - this operation is not supportedpublic boolean retainAll(Collection<?> c)
retainAll
in interface Collection<E>
UnsupportedOperationException
- - this operation is not supportedpublic Object[] toArray()
toArray
in interface Collection<E>
UnsupportedOperationException
- - this operation is not supportedpublic <T> T[] toArray(T[] a)
toArray
in interface Collection<E>
UnsupportedOperationException
- - this operation is not supportedpublic E element()
element
in interface Queue<E>
UnsupportedOperationException
- - this operation is not supportedpublic E peek()
peek
in interface Queue<E>
UnsupportedOperationException
- - this operation is not supportedpublic E remove()
remove
in interface Queue<E>
UnsupportedOperationException
- - this operation is not supportedCopyright © 2000-2020 Apache Software Foundation. All Rights Reserved.