Package zmq.poll

Class PollerBase

  • All Implemented Interfaces:
    java.lang.Runnable
    Direct Known Subclasses:
    Poller
    abstract class PollerBase
extends java.lang.Object
implements java.lang.Runnable

    • Nested Class Summary

      Nested Classes 
      Modifier and Type Class Description
      private static class  PollerBase.TimerInfo  

    • Constructor Summary

      Constructors 
      Modifier Constructor Description
      protected PollerBase​(java.lang.String name)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void addTimer​(long timeout, IPollEvents sink, int id)  
      protected void adjustLoad​(int amount)  
      void cancelTimer​(IPollEvents sink, int id)  
      (package private) long clock()  
      (package private) java.lang.Thread createWorker​(java.lang.String name)  
      protected long executeTimers()  
      int getLoad()  
      (package private) boolean isEmpty()  

      • Methods inherited from class java.lang.Object

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

      • Methods inherited from interface java.lang.Runnable

        run

    • Field Detail

      • load

        private final java.util.concurrent.atomic.AtomicInteger load

      • worker

        protected final java.lang.Thread worker

      • changed

        private boolean changed

    • Constructor Detail

      • PollerBase

        protected PollerBase​(java.lang.String name)

    • Method Detail

      • createWorker

        java.lang.Thread createWorker​(java.lang.String name)

      • clock

        long clock()

      • isEmpty

        final boolean isEmpty()

      • getLoad

        public final int getLoad()

      • adjustLoad

        protected void adjustLoad​(int amount)

      • addTimer

        public void addTimer​(long timeout,
                     IPollEvents sink,
                     int id)

      • cancelTimer

        public void cancelTimer​(IPollEvents sink,
                        int id)

      • executeTimers

        protected long executeTimers()