Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 196 for Lock (0.02 seconds)

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

       *
       * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST);
       *
       * lockA.lock();
       *
       * lockB.lock(); // will throw an IllegalStateException
       * lockC.lock(); // will throw an IllegalStateException
       *
       * lockA.lock(); // reentrant acquisition is okay
       * }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Apr 01 17:27:13 GMT 2026
    - 36K bytes
    - Click Count (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        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();
          } finally {
            lock.unlock();
          }
        }
    
        @Override
    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)
  3. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        final Lock lock;
    
        LockingThread(Lock lock) {
          this.lock = lock;
        }
    
        @Override
        public void run() {
          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    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. guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        final Lock lock;
    
        LockingThread(Lock lock) {
          this.lock = lock;
        }
    
        @Override
        public void run() {
          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    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)
  5. guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

        }
    
        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();
          } finally {
            lock.unlock();
          }
        }
    
        @Override
    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-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.SmallLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
    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)
  7. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.SmallLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(50, ReentrantLock::new))
            .add(new Striped.LargeLazyStriped<Lock>(64, ReentrantLock::new))
            .add(new Striped.SmallLazyStriped<Semaphore>(50, SEMAPHORE_SUPPLER))
    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)
  8. android/guava/src/com/google/common/util/concurrent/Monitor.java

        }
        ReentrantLock lock = this.lock;
        lock.lock();
    
        boolean satisfied = false;
        try {
          return satisfied = guard.isSatisfied();
        } finally {
          if (!satisfied) {
            lock.unlock();
          }
        }
      }
    
      /**
       * Enters this monitor if the guard is satisfied. Blocks at most the given time acquiring the
       * lock, but does not wait for the guard to be satisfied.
    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)
  9. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

      private final Object lock = new Object();
    
      /**
       * The runnable, executor pairs to execute. This acts as a stack threaded through the {@link
       * RunnableExecutorPair#next} field.
       */
      @GuardedBy("lock")
      private @Nullable RunnableExecutorPair runnables;
    
      @GuardedBy("lock")
      private boolean executed;
    
      /** Creates a new, empty {@link ExecutionList}. */
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Tue Feb 10 11:51:21 GMT 2026
    - 6.9K bytes
    - Click Count (0)
  10. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingConnectionListener.kt

      }
    
      private fun logEvent(e: ConnectionEvent) {
        if (e.connection != null) {
          assertThat(Thread.holdsLock(e.connection), "Called with lock $${e.connection}")
            .isFalse()
        }
        for (lock in forbiddenLocks) {
          assertThat(Thread.holdsLock(lock), "Called with lock $lock")
            .isFalse()
        }
    
        if (enforceOrder) {
          checkForStartEvent(e)
        }
    
        eventSequence.offer(e)
      }
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 5.8K bytes
    - Click Count (0)
Back to Top