Class RegularScheduler

    • Field Detail

      • tasksToSchedule

        protected final java.util.List<Tuple2<java.lang.Runnable,​java.time.Duration>> tasksToSchedule
      • schedulersList

        protected final java.util.List<java.util.concurrent.ScheduledFuture<?>> schedulersList
    • Constructor Detail

      • RegularScheduler

        protected RegularScheduler()
    • Method Detail

      • schedule

        public RegularScheduler schedule​(java.lang.Runnable r,
                                         java.time.Duration timeInterval)
      • stop

        public void stop()
        Specified by:
        stop in interface Stoppable
      • join

        public void join()
                  throws java.lang.InterruptedException
        Specified by:
        join in interface Joinable
        Throws:
        java.lang.InterruptedException