- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 109 for permit (0.06 seconds)
-
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); } public void testDoubleMinValueCanAcquireExactlyOnce() { RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch); assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring an additional permit", r.tryAcquire());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 22K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring secondary permit", r.tryAcquire()); } public void testDoubleMinValueCanAcquireExactlyOnce() { RateLimiter r = RateLimiter.create(Double.MIN_VALUE, stopwatch); assertTrue("Unable to acquire initial permit", r.tryAcquire()); assertFalse("Capable of acquiring an additional permit", r.tryAcquire());
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 22K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} /** * Requests a permit from the semaphore with a timeout and asserts that operation completed in * the expected timeframe. */ void tryAcquireSuccessfully(long timeoutMillis) { assertTrue(tryAcquireUninterruptibly(semaphore, timeoutMillis, MILLISECONDS)); completed.assertCompletionExpected(); } void tryAcquireSuccessfully(int permits, long timeoutMillis) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} /** * Requests a permit from the semaphore with a timeout and asserts that operation completed in * the expected timeframe. */ void tryAcquireSuccessfully(long timeoutMillis) { assertTrue(tryAcquireUninterruptibly(semaphore, timeoutMillis, MILLISECONDS)); completed.assertCompletionExpected(); } void tryAcquireSuccessfully(int permits, long timeoutMillis) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedPriorityBlockingQueue.java
* unbounded, attempted additions may fail due to resource exhaustion (causing {@code * OutOfMemoryError}). This class does not permit {@code null} elements. A priority queue relying on * {@linkplain Comparable natural ordering} also does not permit insertion of non-comparable objects * (doing so results in {@code ClassCastException}). *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 23 21:06:42 GMT 2026 - 19K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java
return Integer.parseInt(ComponentUtil.getFessConfig().getOrDefault(getConfigPrefix() + ".max.concurrent.requests", "5")); } /** * Gets the timeout for waiting to acquire a concurrency permit (ms). * Default is 30000ms. Override or configure via rag.llm.{provider}.concurrency.wait.timeout. * * @return the wait timeout in milliseconds */ protected long getConcurrencyWaitTimeoutMs() {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 72K bytes - Click Count (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/Cache.kt
* } else { * // The resource was not cached. * } * ``` * * This technique works even better in situations where a stale response is better than no response. * To permit stale cached responses, use the `max-stale` directive with the maximum staleness in * seconds: * * ```java * Request request = new Request.Builder() * .cacheControl(new CacheControl.Builder()Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Fri Mar 20 09:13:37 GMT 2026 - 26.9K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* that use {@code comparator} to determine the least and greatest elements. */ /* * TODO(cpovirk): Change to Comparator<? super B> to permit Comparator<@Nullable ...> and * Comparator<SupertypeOfB>? What we have here matches the immutable collections, but those also * expose a public Builder constructor that accepts "? super." So maybe we should do *that*Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
guava/src/com/google/common/collect/MinMaxPriorityQueue.java
* that use {@code comparator} to determine the least and greatest elements. */ /* * TODO(cpovirk): Change to Comparator<? super B> to permit Comparator<@Nullable ...> and * Comparator<SupertypeOfB>? What we have here matches the immutable collections, but those also * expose a public Builder constructor that accepts "? super." So maybe we should do *that*Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 13:11:08 GMT 2026 - 34K bytes - Click Count (0) -
pom.xml
<id>build</id> <activation> <activeByDefault>true</activeByDefault> </activation> <properties> <test.include.path>**/*Test.java</test.include.path> <test.command.args>--illegal-access=permit -Djava.awt.headless=true</test.command.args> </properties> </profile> <profile> <id>integrationTests</id> <properties> <test.include.path>**/*Tests.java</test.include.path> <test.command.args />
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Thu Mar 19 07:04:54 GMT 2026 - 49.9K bytes - Click Count (0)