Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 85 for period (0.23 sec)

  1. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

       * second" (commonly referred to as <i>QPS</i>, queries per second), and a <i>warmup period</i>,
       * during which the {@code RateLimiter} smoothly ramps up its rate, until it reaches its maximum
       * rate at the end of the period (as long as there are enough requests to saturate it). Similarly,
       * if the {@code RateLimiter} is left <i>unused</i> for a duration of {@code warmupPeriod}, it
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 18.2K bytes
    - Viewed (0)
  2. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        for (int i = 0; i < 8; i++) {
          limiter.acquire(); // // #1
        }
        stopwatch.sleepMillis(4500); // #2: back to cold state (warmup period + repay last acquire)
        for (int i = 0; i < 3; i++) { // only three steps, we're somewhere in the warmup period
          limiter.acquire(); // #3
        }
    
        limiter.setRate(4.0); // double the rate!
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

      }
    
      @Override
      public final ScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        return delegate.scheduleAtFixedRate(wrapTask(command), initialDelay, period, unit);
      }
    
      @Override
      public final ScheduledFuture<?> scheduleWithFixedDelay(
          Runnable command, long initialDelay, long delay, TimeUnit unit) {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 2.4K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        for (int i = 0; i < 8; i++) {
          limiter.acquire(); // // #1
        }
        stopwatch.sleepMillis(4500); // #2: back to cold state (warmup period + repay last acquire)
        for (int i = 0; i < 3; i++) { // only three steps, we're somewhere in the warmup period
          limiter.acquire(); // #3
        }
    
        limiter.setRate(4.0); // double the rate!
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * of the function, thus time. Thus, the RateLimiter becomes /faster/ after a period of
       * underutilization. If, on the other hand, we pick a function that goes /above/ that horizontal
       * line, then it means that the area (time) is increased, thus storedPermits are more costly than
       * fresh permits, thus the RateLimiter becomes /slower/ after a period of underutilization.
       *
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 19.3K bytes
    - Viewed (0)
  6. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

          return 0;
        }
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
  7. android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java

          return NeverScheduledFuture.create();
        }
    
        @Override
        public ListenableScheduledFuture<?> scheduleAtFixedRate(
            Runnable command, long initialDelay, long period, TimeUnit unit) {
          return NeverScheduledFuture.create();
        }
    
        @Override
        public ListenableScheduledFuture<?> scheduleWithFixedDelay(
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Fri May 26 22:04:00 GMT 2023
    - 6.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        @Override
        public ScheduledFuture<?> scheduleAtFixedRate(
            Runnable command, long initialDelay, long period, TimeUnit unit) {
          assertThat(command).isInstanceOf(WrappedRunnable.class);
          lastMethodCalled = "scheduleAtFixedRate";
          lastInitialDelay = initialDelay;
          lastDelay = period;
          lastUnit = unit;
          return null;
        }
    
        @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 16 19:54:45 GMT 2020
    - 7.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

         * @param initialDelay the time to delay first execution
         * @param period the period between successive executions of the task
         * @param unit the time unit of the initialDelay and period parameters
         */
        @SuppressWarnings("GoodTime") // should accept a java.time.Duration
        public static Scheduler newFixedRateSchedule(
            final long initialDelay, final long period, final TimeUnit unit) {
          checkNotNull(unit);
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Dec 13 19:45:20 GMT 2023
    - 25.8K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

          return 0;
        }
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleAtFixedRate(
          Runnable command, long initialDelay, long period, TimeUnit unit) {
        throw new UnsupportedOperationException("scheduleAtFixedRate is not supported.");
      }
    
      @Override
      public ListenableScheduledFuture<?> scheduleWithFixedDelay(
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Oct 06 00:47:57 GMT 2021
    - 6.4K bytes
    - Viewed (0)
Back to top