Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 51 for unblock (0.12 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnException() throws Exception {
        throwException = true;
    
        // Start up the task and unblock the latch to finish the task.
        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
        ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/ListenableFutureTaskTest.java

        assertTrue(task.isDone());
        assertFalse(task.isCancelled());
      }
    
      public void testListenerCalledOnException() throws Exception {
        throwException = true;
    
        // Start up the task and unblock the latch to finish the task.
        exec.execute(task);
        runLatch.await();
        taskLatch.countDown();
    
        ExecutionException e = assertThrows(ExecutionException.class, () -> task.get(5, SECONDS));
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 4.7K bytes
    - Click Count (0)
  3. 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)
  4. 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)
  5. CHANGELOG/CHANGELOG-1.32.md

    Guaranteed pods with integer CPU requests on nodes with static CPU & Memory policy configured is not allowed for the beta release of in-place resize. The feature gate `InPlacePodVerticalScalingExclusiveCPUs` defaults to `false`, but can be enabled to unblock development on ([#127262](https://github.com/kubernetes/kubernetes/issues/127262), [@tallclair](https://github.com/tallclair)) [SIG Node]. ([#128287](https://github.com/kubernetes/kubernetes/pull/128287), [@esotsal](https://github.com/esotsal)) [SIG...
    Created: Fri Apr 03 09:05:14 GMT 2026
    - Last Modified: Thu Feb 26 23:58:21 GMT 2026
    - 470.5K bytes
    - Click Count (0)
  6. docs/en/docs/release-notes.md

    ```Python
    async def do_something():
        try:
            yield something
        finally:
            some_cleanup()
    ```
    
    ...that way the `finally` block is run regardless of any exception that might happen.
    
    ### Features
    
    Created: Sun Apr 05 07:19:11 GMT 2026
    - Last Modified: Fri Apr 03 12:07:04 GMT 2026
    - 631K bytes
    - Click Count (0)
  7. 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)
  8. 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)
  9. 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)
  10. RELEASE.md

    *   Adds `Dataset.interleave` transformation.
    *   Add `ConcatenateDataset` to concatenate two datasets.
    *   Added Mobilenet support to TensorFlow for Poets training script.
    *   Adds a block cache to the GCS filesystem with configurable block size and
        count.
    *   SinhArcSinh bijector added.
    *   Added `Dataset.list_files` API.
    *   Introduces new operations and Python bindings for the Cloud TPU.
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Mon Mar 30 18:31:38 GMT 2026
    - 746.5K bytes
    - Click Count (3)
Back to Top