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()