Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 45 for permits (0.17 sec)

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

     * Law</a>).
     *
     * <p>A {@code RateLimiter} is defined primarily by the rate at which permits are issued. Absent
     * additional configuration, permits will be distributed at a fixed rate, defined in terms of
     * permits per second. Permits will be distributed smoothly, with the delay between individual
     * permits being adjusted to ensure that the configured rate is maintained.
     *
    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. android/guava/src/com/google/common/util/concurrent/SmoothRateLimiter.java

       * "permits / time", thus "1 / rate = time / permits". Thus, "1/rate" (time / permits) times
       * "permits" gives time, i.e., integrals on this function (which is what storedPermitsToWaitTime()
       * computes) correspond to minimum intervals between subsequent requests, for the specified number
       * of requested permits.
       *
    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)
  3. guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        assertTrue("Should acquire initial permit", rateLimiter.tryAcquire());
        assertFalse("Should not acquire additional permit", rateLimiter.tryAcquire());
        stopwatch.sleepMillis(5000);
        assertFalse(
            "Should not acquire additional permit even after sleeping", rateLimiter.tryAcquire());
      }
    
      private long measureTotalTimeMillis(RateLimiter rateLimiter, int permits, Random random) {
    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-tests/test/com/google/common/util/concurrent/RateLimiterTest.java

        assertTrue("Should acquire initial permit", rateLimiter.tryAcquire());
        assertFalse("Should not acquire additional permit", rateLimiter.tryAcquire());
        stopwatch.sleepMillis(5000);
        assertFalse(
            "Should not acquire additional permit even after sleeping", rateLimiter.tryAcquire());
      }
    
      private long measureTotalTimeMillis(RateLimiter rateLimiter, int permits, Random random) {
    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)
  5. android/guava/src/com/google/common/util/concurrent/Striped.java

       * with the specified number of permits.
       *
       * @param stripes the minimum number of stripes (semaphores) required
       * @param permits the number of permits in each semaphore
       * @return a new {@code Striped<Semaphore>}
       */
      public static Striped<Semaphore> semaphore(int stripes, int permits) {
        return custom(stripes, () -> new PaddedSemaphore(permits));
      }
    
      /**
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 10 20:55:18 GMT 2023
    - 20.3K bytes
    - Viewed (1)
  6. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * timeout, unit)} uninterruptibly.
       *
       * @since 18.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public static boolean tryAcquireUninterruptibly(
          Semaphore semaphore, int permits, long timeout, TimeUnit unit) {
        boolean interrupted = false;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 14.4K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        private void tryAcquireUnsuccessfully(int permits, long timeoutMillis) {
          assertFalse(tryAcquireUninterruptibly(semaphore, permits, timeoutMillis, MILLISECONDS));
          completed.assertCompletionNotExpected(timeoutMillis);
        }
    
        private void scheduleRelease(long countdownInMillis) {
          DelayedActionRunnable toRun = new Release(semaphore, countdownInMillis);
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 31.7K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        private void tryAcquireUnsuccessfully(int permits, long timeoutMillis) {
          assertFalse(tryAcquireUninterruptibly(semaphore, permits, timeoutMillis, MILLISECONDS));
          completed.assertCompletionNotExpected(timeoutMillis);
        }
    
        private void scheduleRelease(long countdownInMillis) {
          DelayedActionRunnable toRun = new Release(semaphore, countdownInMillis);
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 30.9K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/package-info.java

     *       with the same key. Some behaviors of {@link Multimap} are left unspecified and are provided
     *       only by the subtypes mentioned below.
     *   <dt>{@link ListMultimap}
     *   <dd>An extension of {@link Multimap} which permits duplicate entries, supports random access of
     *       values for a particular key, and has <i>partially order-dependent equality</i> as defined
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Jul 06 16:29:45 GMT 2023
    - 5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/graph/DirectedGraphConnections.java

          if (orderedNodeConnections != null) {
            orderedNodeConnections.remove(new NodeConnection.Succ<>((N) node));
          }
        }
    
        /*
         * TODO(cpovirk): `return (V) removedValue` once our checker permits that.
         *
         * (We promoted a class of warnings into errors because sometimes they indicate real problems.
         * But now we need to "undo" some instance of spurious errors, as discussed in
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Feb 20 17:00:05 GMT 2024
    - 18K bytes
    - Viewed (0)
Back to top