Class DefaultSpeculativeRequestExecutionPolicy

    • Field Detail

      • firstSpeculativeRequestTimeout

        final int firstSpeculativeRequestTimeout
      • maxSpeculativeRequestTimeout

        final int maxSpeculativeRequestTimeout
      • backoffMultiplier

        final float backoffMultiplier
    • Constructor Detail

      • DefaultSpeculativeRequestExecutionPolicy

        public DefaultSpeculativeRequestExecutionPolicy​(int firstSpeculativeRequestTimeout,
                                                        int maxSpeculativeRequestTimeout,
                                                        float backoffMultiplier)
    • Method Detail

      • initiateSpeculativeRequest

        public java.util.concurrent.ScheduledFuture<?> initiateSpeculativeRequest​(java.util.concurrent.ScheduledExecutorService scheduler,
                                                                                  SpeculativeRequestExecutor requestExecutor)
        Initialize the speculative request execution policy.
        Specified by:
        initiateSpeculativeRequest in interface SpeculativeRequestExecutionPolicy
        Parameters:
        scheduler - The scheduler service to issue the speculative request
        requestExecutor - The executor is used to issue the actual speculative requests
        Returns:
        ScheduledFuture, in case caller needs to cancel it.