- Sort Score
- Num 10 results
- Language All
Results 1 - 5 of 5 for semaphore (0.17 seconds)
-
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) -
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) -
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) -
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) -
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)