Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 9 of 9 for ReentrantLock (0.12 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 18 15:05:43 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  5. src/main/java/jcifs/internal/smb2/Smb2SigningDigest.java

        /**
         *
         */
        private static final int SIGNATURE_OFFSET = 48;
        private static final int SIGNATURE_LENGTH = 16;
        private final Mac digest;
        private final ReentrantLock signingLock = new ReentrantLock();
        private byte[] signingKey;
        private final String algorithmName;
        private final java.security.Provider provider;
        private volatile boolean closed = false;
    
        /**
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 9.9K 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 Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

    import java.util.concurrent.Semaphore;
    import java.util.concurrent.TimeUnit;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReentrantLock;
    import junit.framework.TestCase;
    import org.jspecify.annotations.NullUnmarked;
    
    /**
     * Tests for {@link Uninterruptibles}.
     *
     * @author Anthony Zana
     */
    @NullUnmarked
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 16 17:42:14 UTC 2025
    - 31.7K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/Striped.java

    import java.util.concurrent.atomic.AtomicReferenceArray;
    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    import java.util.concurrent.locks.ReadWriteLock;
    import java.util.concurrent.locks.ReentrantLock;
    import java.util.concurrent.locks.ReentrantReadWriteLock;
    import org.jspecify.annotations.Nullable;
    
    /**
     * A striped {@code Lock/Semaphore/ReadWriteLock}. This offers the underlying lock striping similar
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

       * opportunistically, just to simplify some locking and avoid separate construction.
       */
      @SuppressWarnings("serial") // This class is never serialized.
      abstract static class Segment<
              K, V, E extends InternalEntry<K, V, E>, S extends Segment<K, V, E, S>>
          extends ReentrantLock {
    
        /*
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
Back to top