Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for ReentrantLock (0.23 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  2. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/Monitor.java

    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.function.BooleanSupplier;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A synchronization abstraction supporting waiting on arbitrary boolean conditions.
     *
     * <p>This class is intended as a replacement for {@link ReentrantLock}. Code using {@code Monitor}
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 42.8K bytes
    - Viewed (0)
  4. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  5. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  6. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  7. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Tue May 13 17:27:14 UTC 2025
    - 8.5K bytes
    - Viewed (0)
  8. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  9. android/guava-tests/benchmark/com/google/common/util/concurrent/StripedBenchmark.java

    import com.google.common.primitives.Ints;
    import java.util.ArrayList;
    import java.util.Collections;
    import java.util.List;
    import java.util.Random;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    import org.jspecify.annotations.NullUnmarked;
    
    /** A benchmark comparing the various striped implementations. */
    @VmOptions({"-Xms12g", "-Xmx12g", "-d64"})
    @NullUnmarked
    public class StripedBenchmark {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4K bytes
    - Viewed (0)
  10. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.8K bytes
    - Viewed (0)
Back to top