Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for semaphore (0.17 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertInterrupted();
      }
    
      // Semaphore.tryAcquire() tests
      public void testTryAcquireWithNoWait() {
        Stopwatch stopwatch = Stopwatch.createStarted();
        Semaphore semaphore = new Semaphore(99);
        assertTrue(tryAcquireUninterruptibly(semaphore, 0, MILLISECONDS));
        assertTrue(tryAcquireUninterruptibly(semaphore, -42, MILLISECONDS));
        assertTrue(tryAcquireUninterruptibly(semaphore, LONG_DELAY_MS, MILLISECONDS));
    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)
  2. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        assertInterrupted();
      }
    
      // Semaphore.tryAcquire() tests
      public void testTryAcquireWithNoWait() {
        Stopwatch stopwatch = Stopwatch.createStarted();
        Semaphore semaphore = new Semaphore(99);
        assertTrue(tryAcquireUninterruptibly(semaphore, 0, MILLISECONDS));
        assertTrue(tryAcquireUninterruptibly(semaphore, -42, MILLISECONDS));
        assertTrue(tryAcquireUninterruptibly(semaphore, LONG_DELAY_MS, MILLISECONDS));
    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)
  3. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            Striped.custom(100, FAIR_LOCK_SUPPLER),
            Striped.custom(256, FAIR_LOCK_SUPPLER),
            Striped.semaphore(100, 1),
            Striped.semaphore(256, 1));
      }
    
      private static final Supplier<Lock> FAIR_LOCK_SUPPLER = () -> new ReentrantLock(true);
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER = () -> new Semaphore(1, false);
    
      private static List<Striped<?>> weakImplementations() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            Striped.custom(100, FAIR_LOCK_SUPPLER),
            Striped.custom(256, FAIR_LOCK_SUPPLER),
            Striped.semaphore(100, 1),
            Striped.semaphore(256, 1));
      }
    
      private static final Supplier<Lock> FAIR_LOCK_SUPPLER = () -> new ReentrantLock(true);
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER = () -> new Semaphore(1, false);
    
      private static List<Striped<?>> weakImplementations() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 8.1K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java

        /** The scheduled task for periodic availability checks. */
        protected TimeoutTask availabilityCheckTask;
    
        /** Semaphore for limiting concurrent LLM requests. Initialized lazily in init(). */
        protected volatile Semaphore concurrencyLimiter;
    
        /** The system prompt for LLM interactions. */
        protected String systemPrompt;
        /** The prompt for detecting user intent. */
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 21 06:04:58 GMT 2026
    - 72K bytes
    - Click Count (0)
Back to Top