E
- public class UnboundedQueue<E> extends java.util.AbstractQueue<E> implements InternalQueue<E>
Constructor and Description |
---|
UnboundedQueue(int priority) |
Modifier and Type | Method and Description |
---|---|
boolean |
contains(java.lang.Object o) |
int |
drainTo(java.util.Collection<? super E> c)
Drain items from this queue to the specified collection
|
int |
drainTo(java.util.Collection<? super E> c,
int maxElements)
Drain items from this queue to the specified collection
|
int |
getCapacity()
Return the capacity of the queue
|
java.util.concurrent.locks.Condition |
getNotFullCond()
Get not full condition
|
int |
getPriority()
Get the Priority of the queue
|
java.util.Iterator<E> |
iterator() |
boolean |
offer(E e) |
E |
peek() |
E |
poll() |
int |
remainingCapacity()
Remaining capacity of the queue.
|
boolean |
remove(java.lang.Object o) |
void |
setNotFullCond(java.util.concurrent.locks.Condition condition)
Get not full condition
|
void |
setPriority(int p)
Set the priority
|
int |
size() |
containsAll, isEmpty, removeAll, retainAll, toArray, toArray, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
public java.util.Iterator<E> iterator()
public int size()
public int getPriority()
InternalQueue
getPriority
in interface InternalQueue<E>
public void setPriority(int p)
InternalQueue
setPriority
in interface InternalQueue<E>
p
- prioritypublic java.util.concurrent.locks.Condition getNotFullCond()
InternalQueue
getNotFullCond
in interface InternalQueue<E>
public void setNotFullCond(java.util.concurrent.locks.Condition condition)
InternalQueue
setNotFullCond
in interface InternalQueue<E>
condition
- conditionpublic int drainTo(java.util.Collection<? super E> c)
InternalQueue
drainTo
in interface InternalQueue<E>
c
- collection to add itempublic int drainTo(java.util.Collection<? super E> c, int maxElements)
InternalQueue
drainTo
in interface InternalQueue<E>
c
- collection to add itemmaxElements
- maximum number of element to drainpublic int remainingCapacity()
InternalQueue
remainingCapacity
in interface InternalQueue<E>
public int getCapacity()
InternalQueue
getCapacity
in interface InternalQueue<E>
public boolean contains(java.lang.Object o)
Copyright © 2005-2022 Apache Software Foundation. All Rights Reserved.