Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 104 for permits (0.07 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/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.
       *
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 19.3K bytes
    - Viewed (0)
  4. 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)
  5. 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)
  6. 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)
  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. LICENSE

    incorporate.  Many developers of free software are heartened and
    encouraged by the resulting cooperation.  However, in the case of
    software used on network servers, this result may fail to come about.
    The GNU General Public License permits making a modified version and
    letting the public access it on a server without ever releasing its
    source code to the public.
    
      The GNU Affero General Public License is designed specifically to
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Apr 23 18:58:53 UTC 2021
    - 33.7K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb1/Config.java

            }
        }
    
        // supress javadoc constructor summary by removing 'protected'
        Config() {}
    
        /**
         * Set the default properties of the static Properties used by <tt>Config</tt>. This permits
         * a different Properties object/file to be used as the source of properties for
         * use by the jCIFS library. The Properties must be set <i>before jCIFS
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Fri Mar 22 21:10:40 UTC 2019
    - 11.3K bytes
    - Viewed (0)
Back to top