Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for newCondition (0.37 seconds)

  1. android/guava/src/com/google/common/util/concurrent/ForwardingLock.java

        return delegate().tryLock(time, unit);
      }
    
      @Override
      public void unlock() {
        delegate().unlock();
      }
    
      @Override
      public Condition newCondition() {
        return delegate().newCondition();
      }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 23 15:26:56 GMT 2025
    - 1.6K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/Striped.java

          this.strongReference = strongReference;
        }
    
        @Override
        Lock delegate() {
          return delegate;
        }
    
        @Override
        public Condition newCondition() {
          return new WeakSafeCondition(delegate.newCondition(), strongReference);
        }
      }
    
      /** Condition object that ensures a strong reference is retained to a specified object. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Sep 16 22:01:32 GMT 2025
    - 20.6K bytes
    - Click Count (0)
  3. android/guava/src/com/google/common/util/concurrent/Monitor.java

     *
     * {@snippet :
     * public class SafeBox<V> {
     *   private V value;
     *   private final ReentrantLock lock = new ReentrantLock();
     *   private final Condition valuePresent = lock.newCondition();
     *   private final Condition valueAbsent = lock.newCondition();
     *
     *   public V get() throws InterruptedException {
     *     lock.lock();
     *     try {
     *       while (value == null) {
     *         valuePresent.await();
     *       }
    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)
  4. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

          return testCondition;
        }
    
        static TestCondition create() {
          Lock lock = new ReentrantLock();
          Condition condition = lock.newCondition();
          return new TestCondition(lock, condition);
        }
    
        @Override
        public void await() throws InterruptedException {
          lock.lock();
          try {
            condition.await();
    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)
  5. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

          return testCondition;
        }
    
        static TestCondition create() {
          Lock lock = new ReentrantLock();
          Condition condition = lock.newCondition();
          return new TestCondition(lock, condition);
        }
    
        @Override
        public void await() throws InterruptedException {
          lock.lock();
          try {
            condition.await();
    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)
Back to Top