- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 53 for unlocks (0.12 seconds)
-
internal/lru/lru.go
func (c *LRU[K, V]) Remove(key K) bool { c.mu.Lock() defer c.mu.Unlock() if ent, ok := c.items[key]; ok { c.removeElement(ent) return true } return false } // RemoveOldest removes the oldest item from the cache. func (c *LRU[K, V]) RemoveOldest() (key K, value V, ok bool) { c.mu.Lock() defer c.mu.Unlock() if ent := c.evictList.Back(); ent != nil { c.removeElement(ent)
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) -
src/test/java/org/codelibs/fess/mylasta/direction/sponsor/FessCurtainBeforeHookTest.java
// This test verifies that the DBFluteSystem is properly unlocked and locked // during the process, though we can't directly test the lock state // When try { curtainBeforeHook.processDBFluteSystem(); // Then - if we get here without exception, the unlock/lock worked DfFinalTimeZoneProvider provider = getDBFluteSystemTimeZoneProvider();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) -
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-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Tests for {@link Uninterruptibles}. * * @author Anthony ZanaCreated: 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/util/concurrent/CycleDetectingLockFactory.java
* <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() * <li>5 levels: average of 103ns per lock()/unlock() * <li>10 levels: average of 184ns per lock()/unlock() * <li>20 levels: average of 393ns per lock()/unlock() * </ul> * </ul> *
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Wed Apr 01 17:27:13 GMT 2026 - 36K 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-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.Semaphore; import java.util.concurrent.TimeUnit; import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; import junit.framework.TestCase; import org.jspecify.annotations.NullUnmarked; /** * Tests for {@link Uninterruptibles}. * * @author Anthony ZanaCreated: 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)