org.eclipse.spi.net4j
Class Channel.SendQueue

java.lang.Object
  java.util.AbstractCollection<E>
      java.util.AbstractQueue<E>
          java.util.concurrent.ConcurrentLinkedQueue<IBuffer>
              org.eclipse.spi.net4j.Channel.SendQueue

All Implemented Interfaces:

Serializable, Iterable<IBuffer>, Collection<IBuffer>, Queue<IBuffer>

Enclosing class:

Channel

protected class Channel.SendQueue

extends ConcurrentLinkedQueue<IBuffer>

A queue that holds buffers that shall be sent. This implementation notifies observers of enqueued and dequeued buffers. The notification's deliberately not synchronized. It shall only be used by O&M tooling to offer (not 100% accurate) statistical insights

Since:

3.0

See Also:

Serialized Form

Channel.SendQueue

protected Channel.SendQueue()

add

public boolean add(IBuffer o)

Specified by:

add in interface Collection<IBuffer>

Specified by:

add in interface Queue<IBuffer>

Overrides:

add in class ConcurrentLinkedQueue<IBuffer>

offer

public boolean offer(IBuffer o)

Specified by:

offer in interface Queue<IBuffer>

Overrides:

offer in class ConcurrentLinkedQueue<IBuffer>

poll

public IBuffer poll()

Specified by:

poll in interface Queue<IBuffer>

Overrides:

poll in class ConcurrentLinkedQueue<IBuffer>

remove

public IBuffer remove()

Specified by:

remove in interface Queue<IBuffer>

Overrides:

remove in class AbstractQueue<IBuffer>

remove

public boolean remove(Object o)

Specified by:

remove in interface Collection<IBuffer>

Overrides:

remove in class ConcurrentLinkedQueue<IBuffer>