- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 17 for Munlock (0.05 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
internal/lru/lru.go
func (c *LRU[K, V]) Contains(key K) (ok bool) { c.mu.RLock() defer c.mu.RUnlock() _, ok = c.items[key] return ok } // Peek returns the key value (or undefined if not found) without updating // the "recently used"-ness of the key. func (c *LRU[K, V]) Peek(key K) (value V, ok bool) { c.mu.RLock() defer c.mu.RUnlock() var ent *Entry[K, V] if ent, ok = c.items[key]; ok { // Expired item check
Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 12.6K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* * <ul> * <li>for an unnested {@code lock()} and {@code unlock()}, a cycle detecting lock takes 38ns as * opposed to the 24ns taken by a plain lock. * <li>for nested locking, the cost increases with the depth of the nesting: * <ul> * <li>2 levels: average of 64ns per lock()/unlock() * <li>3 levels: average of 77ns per lock()/unlock() * <li>4 levels: average of 99ns per lock()/unlock()
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 36K bytes - Click Count (0) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHookTest.java
// Then - if we get here without exception, the unlock/lock worked DfFinalTimeZoneProvider provider = getDBFluteSystemTimeZoneProvider(); // Provider might be null due to reflection limitations, which is ok assertTrue("processDBFluteSystem executed without exception", true); } catch (Exception e) { fail("processDBFluteSystem should handle unlock/lock properly: " + e.getMessage()); }Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Fri Mar 13 23:01:26 GMT 2026 - 8.4K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
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/UninterruptiblesTest.java
try { condition.await(); } finally { lock.unlock(); } } @Override public boolean await(long time, TimeUnit unit) throws InterruptedException { lock.lock(); try { return condition.await(time, unit); } finally { lock.unlock(); } } @Override public void awaitUninterruptibly() {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/src/com/google/common/cache/LocalCache.java
} finally { unlock(); postWriteCleanup(); } } // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { drainReferenceQueues(); } finally { unlock(); } } }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) -
guava/src/com/google/common/cache/LocalCache.java
} finally { unlock(); postWriteCleanup(); } } // reference queues, for garbage collection cleanup /** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { drainReferenceQueues(); } finally { unlock(); } } }Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 148.9K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/MapMakerInternalMap.java
/** Cleanup collected entries when the lock is available. */ void tryDrainReferenceQueues() { if (tryLock()) { try { maybeDrainReferenceQueues(); } finally { unlock(); } } } @GuardedBy("this") void drainKeyReferenceQueue(ReferenceQueue<K> keyReferenceQueue) { Reference<? extends K> ref; int i = 0;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) -
src/main/java/org/codelibs/fess/helper/RateLimitHelper.java
public void blockIp(final String ip, final long durationMs) { blockedIps.put(ip, Boolean.TRUE); logger.info("IP manually blocked: ip={}", ip); } /** * Unblock an IP address. * @param ip the IP address to unblock */ public void unblockIp(final String ip) { blockedIps.invalidate(ip); logger.info("IP unblocked: ip={}", ip); } /**
Created: Tue Mar 31 13:07:34 GMT 2026 - Last Modified: Wed Dec 24 14:16:27 GMT 2025 - 9.4K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java
GcFinalization.awaitClear(garbage); Lock writeLock = striped.get(key).writeLock(); readLock.lock(); try { assertFalse(writeLock.tryLock()); } finally { readLock.unlock(); } } private WeakReference<Object> createGarbage() { return new WeakReference<>(new Object()); } public void testStrongImplementations() {
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)