Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 47 for period (0.48 sec)

  1. 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 May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 21.6K bytes
    - Viewed (0)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

                  @Override
                  public ScheduledFuture<?> scheduleAtFixedRate(
                      Runnable command, long initialDelay, long period, TimeUnit unit) {
                    assertSingleCallWithCorrectParameters(command, initialDelay, period, unit);
                    return new ThrowingScheduledFuture<>();
                  }
                },
                testRunnable);
        assertTrue(called);
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

        @Override
        public ListenableScheduledFuture<?> scheduleAtFixedRate(
            Runnable command, long initialDelay, long period, TimeUnit unit) {
          NeverSuccessfulListenableFutureTask task = new NeverSuccessfulListenableFutureTask(command);
          ScheduledFuture<?> scheduled = delegate.scheduleAtFixedRate(task, initialDelay, period, unit);
          return new ListenableScheduledTask<@Nullable Void>(task, scheduled);
        }
    
        @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Apr 17 16:33:44 GMT 2024
    - 41.8K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java

                  @Override
                  public ScheduledFuture<?> scheduleAtFixedRate(
                      Runnable command, long initialDelay, long period, TimeUnit unit) {
                    assertSingleCallWithCorrectParameters(command, initialDelay, period, unit);
                    return new ThrowingScheduledFuture<>();
                  }
                },
                testRunnable);
        assertTrue(called);
      }
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 22.5K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/testing/GcFinalization.java

     * specified the JVM flag {@code -XX:+DisableExplicitGC}. But in practice, it works very well for
     * ordinary tests.
     *
     * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time
     * period or an interrupt while waiting for the expected event will result in a {@link
     * RuntimeException}.
     *
     * <p>Here's an example that tests a {@code finalize} method:
     *
     * <pre>{@code
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/testing/GcFinalization.java

     * specified the JVM flag {@code -XX:+DisableExplicitGC}. But in practice, it works very well for
     * ordinary tests.
     *
     * <p>Failure of the expected event to occur within an implementation-defined "reasonable" time
     * period or an interrupt while waiting for the expected event will result in a {@link
     * RuntimeException}.
     *
     * <p>Here's an example that tests a {@code finalize} method:
     *
     * <pre>{@code
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:40:56 GMT 2024
    - 11.6K bytes
    - Viewed (0)
Back to top