Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 17 for ReentrantLock (0.06 sec)

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

      private ReentrantReadWriteLock.ReadLock readLockA;
      private ReentrantReadWriteLock.ReadLock readLockB;
      private ReentrantReadWriteLock.ReadLock readLockC;
      private ReentrantReadWriteLock.WriteLock writeLockA;
      private ReentrantReadWriteLock.WriteLock writeLockB;
      private ReentrantReadWriteLock.WriteLock writeLockC;
      private ReentrantLock lock1;
      private ReentrantLock lock2;
      private ReentrantLock lock3;
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/CycleDetectingLockFactoryBenchmark.java

        for (int i = 0; i < lockNestingDepth; i++) {
          plainLocks[i] = new ReentrantLock();
        }
        this.detectingLocks = new Lock[lockNestingDepth];
        for (int i = 0; i < lockNestingDepth; i++) {
          detectingLocks[i] = factory.newReentrantLock("Lock" + i);
        }
      }
    
      @Benchmark
      void unorderedPlainLocks(int reps) {
        lockAndUnlock(new ReentrantLock(), reps);
      }
    
      @Benchmark
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

      public ReentrantLock newReentrantLock(String lockName) {
        return newReentrantLock(lockName, false);
      }
    
      /**
       * Creates a {@link ReentrantLock} with the given fairness policy. The {@code lockName} is used in
       * the warning or exception output to help identify the locks involved in the detected deadlock.
       */
      public ReentrantLock newReentrantLock(String lockName, boolean fair) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  4. guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java

      public ReentrantLock newReentrantLock(String lockName) {
        return newReentrantLock(lockName, false);
      }
    
      /**
       * Creates a {@link ReentrantLock} with the given fairness policy. The {@code lockName} is used in
       * the warning or exception output to help identify the locks involved in the detected deadlock.
       */
      public ReentrantLock newReentrantLock(String lockName, boolean fair) {
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. If
     * the {@link #callAndAssertWaits} method is ever called in a test, the lock-like object must have a
     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        // shutDown or runOneIteration) run concurrently with one another.
        // TODO(lukes): why don't we use ListenableFuture to sequence things? Then we could drop the
        // lock.
        private final ReentrantLock lock = new ReentrantLock();
    
        @WeakOuter
        final class Task implements Runnable {
          @Override
          public void run() {
            lock.lock();
            try {
              /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  7. guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

        // shutDown or runOneIteration) run concurrently with one another.
        // TODO(lukes): why don't we use ListenableFuture to sequence things? Then we could drop the
        // lock.
        private final ReentrantLock lock = new ReentrantLock();
    
        @WeakOuter
        final class Task implements Runnable {
          @Override
          public void run() {
            lock.lock();
            try {
              /*
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * method equivalent to {@link java.util.concurrent.locks.ReentrantLock#hasQueuedThread(Thread)}. If
     * the {@link #callAndAssertWaits} method is ever called in a test, the lock-like object must have a
     * method equivalent to {@link
     * java.util.concurrent.locks.ReentrantLock#hasWaiters(java.util.concurrent.locks.Condition)},
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 11 21:00:51 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock();
            }
          };
    
      private static final Supplier<Lock> FAIR_LOCK_SUPPLER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/StripedTest.java

          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock();
            }
          };
    
      private static final Supplier<Lock> FAIR_LOCK_SUPPLER =
          new Supplier<Lock>() {
            @Override
            public Lock get() {
              return new ReentrantLock(true);
            }
          };
    
      private static final Supplier<Semaphore> SEMAPHORE_SUPPLER =
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 18:19:59 UTC 2025
    - 8.5K bytes
    - Viewed (0)
Back to top