- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 25 for cunlock (0.04 seconds)
-
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-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
Lock lockB = factory.newReentrantLock(OtherOrder.SECOND); lockA.lock(); lockA.lock(); lockB.lock(); lockB.lock(); lockA.unlock(); lockA.unlock(); lockB.unlock(); lockB.unlock(); } public void testExplicitOrdering_acquiringMultipleLocksWithSameRank() { CycleDetectingLockFactory.WithExplicitOrdering<OtherOrder> factory =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K bytes - Click Count (0) -
guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java
Lock lockB = factory.newReentrantLock(OtherOrder.SECOND); lockA.lock(); lockA.lock(); lockB.lock(); lockB.lock(); lockA.unlock(); lockA.unlock(); lockB.unlock(); lockB.unlock(); } public void testExplicitOrdering_acquiringMultipleLocksWithSameRank() { CycleDetectingLockFactory.WithExplicitOrdering<OtherOrder> factory =
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 16.3K 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-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) -
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) -
internal/stmt_store/stmt_store.go
cacheStmt := &Stmt{ Transaction: isTransaction, prepared: make(chan struct{}), } // Cache the Stmt object with the associated key. s.Set(key, cacheStmt) // Unlock after completing initialization to prevent deadlocks. locker.Unlock() // Ensure the prepared channel is closed after the function execution completes. defer close(cacheStmt.prepared) // Prepare the SQL statement using the provided connection.Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:35:55 GMT 2026 - 6.1K 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)