Class ReactorScheduler


  • public final class ReactorScheduler
    extends java.lang.Object
    Utility class used for processing FutureTasks.
    • Field Summary

      Fields 
      Modifier and Type Field Description
      private java.util.Queue<java.util.concurrent.Future<?>> pendingOperations  
    • Field Detail

      • pendingOperations

        private java.util.Queue<java.util.concurrent.Future<?>> pendingOperations
    • Constructor Detail

      • ReactorScheduler

        public ReactorScheduler()
    • Method Detail

      • queueFuture

        public void queueFuture​(java.util.concurrent.Future<?> op)
      • performPendingOperations

        public void performPendingOperations()