org.apache.qpid.util
Class ConcurrentLinkedQueueAtomicSize<E>

java.lang.Object
  extended by java.util.AbstractCollection<E>
      extended by java.util.AbstractQueue<E>
          extended by java.util.concurrent.ConcurrentLinkedQueue<E>
              extended by org.apache.qpid.util.ConcurrentLinkedQueueAtomicSize<E>
All Implemented Interfaces:
Serializable, Iterable<E>, Collection<E>, Queue<E>
Direct Known Subclasses:
ConcurrentLinkedMessageQueueAtomicSize

public class ConcurrentLinkedQueueAtomicSize<E>
extends ConcurrentLinkedQueue<E>

See Also:
Serialized Form

Field Summary
(package private)  AtomicInteger _size
           
 
Constructor Summary
ConcurrentLinkedQueueAtomicSize()
           
 
Method Summary
 boolean offer(E o)
           
 E poll()
           
 boolean remove(Object o)
           
 int size()
           
 
Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue
add, contains, isEmpty, iterator, peek, toArray, toArray
 
Methods inherited from class java.util.AbstractQueue
addAll, clear, element, remove
 
Methods inherited from class java.util.AbstractCollection
containsAll, removeAll, retainAll, toString
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 
Methods inherited from interface java.util.Queue
element, remove
 
Methods inherited from interface java.util.Collection
addAll, clear, containsAll, equals, hashCode, removeAll, retainAll
 

Field Detail

_size

AtomicInteger _size
Constructor Detail

ConcurrentLinkedQueueAtomicSize

public ConcurrentLinkedQueueAtomicSize()
Method Detail

size

public int size()
Specified by:
size in interface Collection<E>
Overrides:
size in class ConcurrentLinkedQueue<E>

offer

public boolean offer(E o)
Specified by:
offer in interface Queue<E>
Overrides:
offer in class ConcurrentLinkedQueue<E>

poll

public E poll()
Specified by:
poll in interface Queue<E>
Overrides:
poll in class ConcurrentLinkedQueue<E>

remove

public boolean remove(Object o)
Specified by:
remove in interface Collection<E>
Overrides:
remove in class ConcurrentLinkedQueue<E>


Licensed to the Apache Software Foundation