Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for newCondition (0.04 sec)

  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();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  2. 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();
      }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 1.6K bytes
    - Viewed (0)
  3. 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. */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  4. 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();
     *       }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

                  delay,
                  unit);
    
          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();
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
Back to top