Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 25 for cunlock (0.04 seconds)

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