- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 36 for Acquiring (0.07 seconds)
-
android/guava/src/com/google/common/util/concurrent/Monitor.java
} } finally { if (interrupted) { Thread.currentThread().interrupt(); } } } /** * Enters this monitor if the guard is satisfied. Blocks indefinitely acquiring the lock, but does * not wait for the guard to be satisfied. * * @return whether the monitor was entered, which guarantees that the guard is now satisfied */ public boolean enterIf(Guard guard) {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Jan 28 22:39:02 GMT 2026 - 43.5K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/RateLimiterTest.java
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()); stopwatch.sleepMillis(Integer.MAX_VALUE);
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
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()); stopwatch.sleepMillis(Integer.MAX_VALUE);
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 17:47:10 GMT 2026 - 22K bytes - Click Count (0) -
docs/en/docs/deployment/https.md
Here's an example of how an HTTPS API could look like, step by step, paying attention mainly to the ideas important for developers. ### Domain Name { #domain-name } It would probably all start by you **acquiring** some **domain name**. Then, you would configure it in a DNS server (possibly your same cloud provider).Created: Sun Apr 05 07:19:11 GMT 2026 - Last Modified: Thu Mar 05 18:13:19 GMT 2026 - 14K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Ordering.java
* enriched {@link Iterable} for pre-Java-8 users. * * <h3>Three types of methods</h3> * * Like other fluent types, there are three types of methods present: methods for <i>acquiring</i>, * <i>chaining</i>, and <i>using</i>. * * <h4>Acquiring</h4> * * <p>The common ways to get an instance of {@code Ordering} are: * * <ul> * <li>Subclass it and implement {@link #compare} instead of implementing {@link Comparator}Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 39.4K bytes - Click Count (0) -
guava/src/com/google/common/collect/Ordering.java
* enriched {@link Iterable} for pre-Java-8 users. * * <h3>Three types of methods</h3> * * Like other fluent types, there are three types of methods present: methods for <i>acquiring</i>, * <i>chaining</i>, and <i>using</i>. * * <h4>Acquiring</h4> * * <p>The common ways to get an instance of {@code Ordering} are: * * <ul> * <li>Subclass it and implement {@link #compare} instead of implementing {@link Comparator}Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 39.4K bytes - Click Count (0) -
src/main/java/org/codelibs/fess/llm/AbstractLlmClient.java
if (concurrencyLimiter == null) { return chat(request); } if (logger.isDebugEnabled()) { logger.debug("[LLM] Acquiring concurrency permit. name={}, availablePermits={}, maxConcurrent={}", getName(), concurrencyLimiter.availablePermits(), getMaxConcurrentRequests()); } try {
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 21 06:04:58 GMT 2026 - 72K bytes - Click Count (0) -
android/guava/src/com/google/common/cache/LocalCache.java
|| (checkTime && (now - e.getWriteTime() < map.refreshNanos))) { // refresh is a no-op if loading is pending // if checkTime, we want to check *after* acquiring the lock if refresh still needs // to be scheduled return null; } // continue returning old value while loading ++modCount;
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 143.5K bytes - Click Count (0) -
src/main/resources/fess_config.properties
# Time-to-live (ms) for instance heartbeat documents. coordinator.heartbeat.ttl=180000 # Time-to-live (ms) for operation lock documents. coordinator.operation.ttl=7200000 # Maximum number of retries for acquiring an operation lock. coordinator.operation.retry=3 # Time-to-live (ms) for event notification documents. coordinator.event.ttl=600000 # ----------------------------------------------------------
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Sat Mar 28 06:59:19 GMT 2026 - 59.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/MapMakerInternalMap.java
runCleanup(); } } /** * Performs routine cleanup prior to executing a write. This should be called every time a write * thread acquires the segment lock, immediately after acquiring the lock. */ @GuardedBy("this") void preWriteCleanup() { runLockedCleanup(); } void runCleanup() { runLockedCleanup(); }
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 89.9K bytes - Click Count (0)