Searched defs:permits (Results 1 - 15 of 15) sorted by relevance

/external/guava/guava/src/com/google/common/util/concurrent/
H A DUninterruptibles.java302 * tryAcquire(permits, timeout, unit)} uninterruptibly.
307 Semaphore semaphore, int permits, long timeout, TimeUnit unit) {
316 return semaphore.tryAcquire(permits, remainingNanos, NANOSECONDS);
306 tryAcquireUninterruptibly( Semaphore semaphore, int permits, long timeout, TimeUnit unit) argument
H A DRateLimiter.java36 * A rate limiter. Conceptually, a rate limiter distributes permits at a
38 * available, and then takes it. Once acquired, permits need not be released.
46 * <p>A {@code RateLimiter} is defined primarily by the rate at which permits
47 * are issued. Absent additional configuration, permits will be distributed at a
48 * fixed rate, defined in terms of permits per second. Permits will be distributed
49 * smoothly, with the delay between individual permits being adjusted to ensure
53 * period during which time the permits issued each second steadily increases until
59 * final RateLimiter rateLimiter = RateLimiter.create(2.0); // rate is "2 permits per second"
70 * a rate of 5000 permits per second:
72 * final RateLimiter rateLimiter = RateLimiter.create(5000.0); // rate = 5000 permits pe
272 acquire(int permits) argument
284 reserve(int permits) argument
319 tryAcquire(int permits) argument
349 tryAcquire(int permits, long timeout, TimeUnit unit) argument
374 reserveAndGetWaitLength(int permits, long nowMicros) argument
394 reserveEarliestAvailable(int permits, long nowMicros) argument
431 checkPermits(int permits) argument
[all...]
H A DSmoothRateLimiter.java38 * another 100ms. At this rate, serving 15 fresh permits (i.e. for an acquire(15) request)
62 * underutilization. So, the requested permits, by an invocation acquire(permits),
64 * - stored permits (if available)
65 * - fresh permits (for any remaining permits)
78 * using all the remaining 7.0 permits, and the remaining 3.0, we serve them by fresh permits
81 * We already know how much time it takes to serve 3 fresh permits: if the rate is
83 * stored permits
269 permitsToTime(double permits) argument
[all...]
H A DStriped.java229 * with the specified number of permits.
232 * @param permits the number of permits in each semaphore
235 public static Striped<Semaphore> semaphore(int stripes, final int permits) { argument
238 return new PaddedSemaphore(permits);
245 * with the specified number of permits.
248 * @param permits the number of permits in each semaphore
251 public static Striped<Semaphore> lazyWeakSemaphore(int stripes, final int permits) { argument
254 return new Semaphore(permits, fals
482 PaddedSemaphore(int permits) argument
[all...]
/external/guava/guava-tests/test/com/google/common/util/concurrent/
H A DRateLimiterTest.java152 limiter.acquire(1); // R0.00, concluding a burst of 5 permits
222 // make sure the areas (times) remain the same, while permits are different
389 * amount of permits in a cool state, where X = rate * timeToCoolDown, and we have
419 private long measureTotalTimeMillis(RateLimiter rateLimiter, int permits, Random random) { argument
421 while (permits > 0) {
422 int nextPermitsToAcquire = Math.max(1, random.nextInt(permits));
423 permits -= nextPermitsToAcquire;
/external/guice/lib/
H A Dguava-16.0.1.jarMETA-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ...
/external/robolectric/v1/lib/main/
H A Dandroid.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/android/ com/android/internal/ com/android/internal/util/ ...
/external/dagger2/lib/
H A Dgoogle-java-format-0.1-20151017.042846-2.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/googlejavaformat/ com/google/googlejavaformat/CloseOp ...
/external/robolectric/v3/runtime/
H A Dandroid-all-4.1.2_r1-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ...
H A Dandroid-all-4.2.2_r1.2-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ...
H A Dandroid-all-4.3_r2-robolectric-0.jarMETA-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ...
H A Dandroid-all-4.4_r1-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ...
H A Dandroid-all-5.0.0_r2-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ...
H A Dandroid-all-5.1.1_r9-robolectric-1.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ...
/external/v8/src/inspector/build/closure-compiler/
H A Dclosure-compiler.jarMETA-INF/MANIFEST.MF META-INF/ com/ com/google/ com/google/debugging/ com/google/debugging/sourcemap/ ...

Completed in 1033 milliseconds