Package akka.remote.artery

Class FixedSizePartitionQueue

  • public class FixedSizePartitionQueue
extends java.lang.Object
    INTERNAL API

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void init​(long id)  
      boolean isEmpty​(long id)  
      boolean nonEmpty​(long id)  
      void offer​(long id, java.lang.Object elem)  
      java.lang.Object poll​(long id)  
      void remove​(long id)  
      int size​(long id)  
      int totalSize()  

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • FixedSizePartitionQueue

        public FixedSizePartitionQueue​(int lanes,
                               int capacity)

    • Method Detail

      • init

        public void init​(long id)

      • isEmpty

        public boolean isEmpty​(long id)

      • nonEmpty

        public boolean nonEmpty​(long id)

      • offer

        public void offer​(long id,
                  java.lang.Object elem)

      • poll

        public java.lang.Object poll​(long id)

      • remove

        public void remove​(long id)

      • size

        public int size​(long id)

      • totalSize

        public int totalSize()