Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 128 for Permit (0.59 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top