Package deltix.data.stream

Class PriorityQueue<T>

  • public final class PriorityQueue<T>
extends java.lang.Object
    Hand-optimized priority queue of MessageSource objects. Analogous to java.util.PriorityQueue <MessageSource <T>>

    • Constructor Summary

      Constructors 
      Constructor Description
      PriorityQueue​(int capacity, boolean ascending, java.util.Comparator<T> c)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void clear()  
      void dump​(java.io.PrintStream ps)  
      void dump​(java.io.PrintStream ps, java.lang.String indent, int pos)  
      deltix.data.stream.MessageSource get​(int idx)  
      void init​(int numObjects)  
      boolean isEmpty()  
      void offer​(deltix.data.stream.MessageSource<T> obj)  
      deltix.data.stream.MessageSource<T> peek()  
      deltix.data.stream.MessageSource<T> poll()  
      boolean remove​(deltix.data.stream.MessageSource<T> obj)  
      int size()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • PriorityQueue

        public PriorityQueue​(int capacity,
                     boolean ascending,
                     java.util.Comparator<T> c)

    • Method Detail

      • dump

        public void dump​(java.io.PrintStream ps)

      • dump

        public void dump​(java.io.PrintStream ps,
                 java.lang.String indent,
                 int pos)

      • init

        public void init​(int numObjects)

      • clear

        public void clear()

      • size

        public int size()

      • isEmpty

        public boolean isEmpty()

      • offer

        public void offer​(deltix.data.stream.MessageSource<T> obj)

      • get

        public deltix.data.stream.MessageSource get​(int idx)

      • remove

        public boolean remove​(deltix.data.stream.MessageSource<T> obj)

      • peek

        public deltix.data.stream.MessageSource<T> peek()

      • poll

        @Nullable
public deltix.data.stream.MessageSource<T> poll()