Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 153 for permits (0.05 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.
     *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.9K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/RateLimiter.java

      }
    
      /**
       * Acquires permits from this {@link RateLimiter} if it can be acquired immediately without delay.
       *
       * <p>This method is equivalent to {@code tryAcquire(permits, 0, anyUnit)}.
       *
       * @param permits the number of permits to acquire
       * @return {@code true} if the permits were acquired, {@code false} otherwise
       * @throws IllegalArgumentException if the requested number of permits is negative or zero
       * @since 14.0
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 21.6K bytes
    - Viewed (0)
  3. 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));
      }
    
      /**
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Jun 26 12:58:35 UTC 2024
    - 20.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) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  5. 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) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 21.8K bytes
    - Viewed (0)
  6. doc/next/6-stdlib/99-minor/net/http/67813.md

    [Transport] and [Server] now have an HTTP2 field which permits
    Registered: Tue Nov 05 11:13:11 UTC 2024
    - Last Modified: Thu Aug 29 17:38:46 UTC 2024
    - 101 bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * timeout, unit)} uninterruptibly.
       *
       * @since 28.0 (but only since 33.4.0 in the Android flavor)
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      public static boolean tryAcquireUninterruptibly(
          Semaphore semaphore, int permits, Duration timeout) {
        return tryAcquireUninterruptibly(
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 19.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      public static boolean tryAcquireUninterruptibly(
          Semaphore semaphore, int permits, Duration timeout) {
        return tryAcquireUninterruptibly(
            semaphore, permits, toNanosSaturated(timeout), TimeUnit.NANOSECONDS);
      }
    
      /**
       * Invokes {@code semaphore.}{@link Semaphore#tryAcquire(int, long, TimeUnit) tryAcquire(permits,
       * timeout, unit)} uninterruptibly.
       *
       * @since 18.0
       */
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 20.1K bytes
    - Viewed (0)
  9. android/guava-testlib/src/com/google/common/collect/testing/google/AbstractBiMapTester.java

          assertFalse(
              "Inverse should not contain value " + reversed.getValue(),
              inv.containsValue(reversed.getValue()));
          /*
           * TODO(cpovirk): This is a bit stronger than super.expectMissing(), which permits a <key,
           * someOtherValue> pair.
           */
          assertNull(
              "Inverse should not return a mapping for key " + reversed.getKey(),
              inv.get(reversed.getKey()));
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 3.2K bytes
    - Viewed (0)
  10. guava-testlib/src/com/google/common/collect/testing/google/AbstractBiMapTester.java

          assertFalse(
              "Inverse should not contain value " + reversed.getValue(),
              inv.containsValue(reversed.getValue()));
          /*
           * TODO(cpovirk): This is a bit stronger than super.expectMissing(), which permits a <key,
           * someOtherValue> pair.
           */
          assertNull(
              "Inverse should not return a mapping for key " + reversed.getKey(),
              inv.get(reversed.getKey()));
        }
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Wed Oct 30 16:15:19 UTC 2024
    - 3.2K bytes
    - Viewed (0)
Back to top