Class Queue<T>

    • Constructor Summary

      Constructors 
      Constructor Description
      Queue()  
    • Constructor Detail

      • Queue

        public Queue()
    • Method Detail

      • putAll

        public void putAll(T[] objs)
                    throws java.io.IOException
        Throws:
        java.io.IOException
      • size

        public int size()
      • tryPut

        public boolean tryPut(T obj)
                       throws java.io.IOException
        Throws:
        java.io.IOException
      • put

        public void put(T obj)
                 throws java.io.IOException
        Throws:
        java.io.IOException
      • registerPutCallback

        public void registerPutCallback(java.lang.Runnable callback)
        callback is invoked any time put is called where the Queue was empty.
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
      • closeExceptionally

        public void closeExceptionally(java.lang.Throwable t)
        Description copied from interface: ExceptionallyCloseable
        Called when an instance of ExceptionallyCloseable is closed due to some exceptional condition revealed by cause.
        Specified by:
        closeExceptionally in interface ExceptionallyCloseable
        Parameters:
        t - The reason for which the object is closed.
      • take

        public T take()
               throws java.io.IOException
        Throws:
        java.io.IOException
      • poll

        public T poll()
               throws java.io.IOException
        Throws:
        java.io.IOException
      • pollAll

        public T[] pollAll(T[] type)
                    throws java.io.IOException
        Throws:
        java.io.IOException
      • pushback

        public void pushback(T v)
      • pushbackAll

        public void pushbackAll(T[] v)