/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | Uninterruptibles.java | 302 * 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 D | RateLimiter.java | 36 * 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 D | SmoothRateLimiter.java | 38 * 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 D | Striped.java | 229 * 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 D | RateLimiterTest.java | 152 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 D | guava-16.0.1.jar | META-INF/MANIFEST.MF META-INF/ META-INF/maven/ META-INF/maven/com. ... |
/external/robolectric/v1/lib/main/ |
H A D | android.jar | META-INF/ META-INF/MANIFEST.MF com/ com/android/ com/android/internal/ com/android/internal/util/ ... |
/external/dagger2/lib/ |
H A D | google-java-format-0.1-20151017.042846-2.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/googlejavaformat/ com/google/googlejavaformat/CloseOp ... |
/external/robolectric/v3/runtime/ |
H A D | android-all-4.1.2_r1-robolectric-0.jar | META-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ... |
H A D | android-all-4.2.2_r1.2-robolectric-0.jar | META-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ... |
H A D | android-all-4.3_r2-robolectric-0.jar | META-INF/ META-INF/MANIFEST.MF android/ android/accessibilityservice/ android/accessibilityservice/AccessibilityService$1.class ... |
H A D | android-all-4.4_r1-robolectric-1.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ... |
H A D | android-all-5.0.0_r2-robolectric-1.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ... |
H A D | android-all-5.1.1_r9-robolectric-1.jar | META-INF/ META-INF/MANIFEST.MF com/ com/google/ com/google/android/ com/google/android/collect/ ... |
/external/v8/src/inspector/build/closure-compiler/ |
H A D | closure-compiler.jar | META-INF/MANIFEST.MF META-INF/ com/ com/google/ com/google/debugging/ com/google/debugging/sourcemap/ ... |