Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 17 for Munlock (0.05 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  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/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)
  3. 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)
  4. android/guava/src/com/google/common/util/concurrent/Monitor.java

     *       return result;
     *     } finally {
     *       lock.unlock();
     *     }
     *   }
     *
     *   public void set(V newValue) throws InterruptedException {
     *     lock.lock();
     *     try {
     *       while (value != null) {
     *         valueAbsent.await();
     *       }
     *       value = newValue;
     *       valuePresent.signal();
     *     } finally {
     *       lock.unlock();
     *     }
     *   }
     * }
     * }
     *
    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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to Top