Package org.eclipse.spi.net4j

Class Channel.SendQueue

  • All Implemented Interfaces:
    java.io.Serializable, java.lang.Iterable<IBuffer>, java.util.Collection<IBuffer>, java.util.Queue<IBuffer>
    Enclosing class:
    Channel
    protected class Channel.SendQueue
extends java.util.concurrent.ConcurrentLinkedQueue<IBuffer>
    A queue that holds buffers that shall be sent. This implementation notifies observers of enqueued and dequeued buffers. The notification is deliberately not synchronized. It shall only be used by O&M tooling to offer (not 100% accurate) statistical insights
    Since:
    3.0
    Author:
    Eike Stepper
    See Also:
    Serialized Form

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected SendQueue()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      boolean offer​(IBuffer o)  
      IBuffer poll()  
      boolean remove​(java.lang.Object o)  

      • Methods inherited from class java.util.concurrent.ConcurrentLinkedQueue

        add, addAll, clear, contains, forEach, isEmpty, iterator, peek, removeAll, removeIf, retainAll, size, spliterator, toArray, toArray, toString

      • Methods inherited from class java.util.AbstractQueue

        element, remove

      • Methods inherited from class java.util.AbstractCollection

        containsAll

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface java.util.Collection

        containsAll, equals, hashCode, parallelStream, stream, toArray

      • Methods inherited from interface java.util.Queue

        element, remove

    • Constructor Detail

      • SendQueue

        protected SendQueue()

    • Method Detail

      • offer

        public boolean offer​(IBuffer o)
        Specified by:
        offer in interface java.util.Queue<IBuffer>
        Overrides:
        offer in class java.util.concurrent.ConcurrentLinkedQueue<IBuffer>

      • poll

        public IBuffer poll()
        Specified by:
        poll in interface java.util.Queue<IBuffer>
        Overrides:
        poll in class java.util.concurrent.ConcurrentLinkedQueue<IBuffer>

      • remove

        public boolean remove​(java.lang.Object o)
        Specified by:
        remove in interface java.util.Collection<IBuffer>
        Overrides:
        remove in class java.util.concurrent.ConcurrentLinkedQueue<IBuffer>