Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 53 for unlocks (0.12 seconds)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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 Zana
    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)
  7. 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)
  8. 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)
  9. 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 Zana
    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)
  10. 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)
Back to Top