Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for canAcquire (0.11 sec)

  1. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ExclusiveAccessResourceLock.java

            if (owner == currentThread) {
                return true;
            }
            if (owner == null && canAcquire()) {
                owner = currentThread;
                return true;
            }
            return false;
        }
    
        protected boolean canAcquire() {
            return true;
        }
    
        @Override
        protected void releaseLock() {
            owner = null;
        }
    
        @Override
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 1.6K bytes
    - Viewed (0)
  2. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLock.java

            super(displayName, coordinationService, owner);
            this.allProjectsLock = allProjectsLock;
        }
    
        @Override
        protected boolean canAcquire() {
            // Either the "all projects" lock is not held, or it is held by this thread
            return !allProjectsLock.isLocked() || allProjectsLock.isLockedByCurrentThread();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  3. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/AllProjectsLock.java

            super(displayName, coordinationService, owner);
        }
    
        @Override
        protected boolean canAcquire() {
            // TODO - should block while some other thread holds a project lock
            return true;
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 1K bytes
    - Viewed (0)
  4. platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/TaskExecutionLock.java

            super(displayName, coordinationService, owner);
            this.stateLock = stateLock;
        }
    
        @Override
        protected boolean canAcquire() {
            return stateLock.isLockedByCurrentThread() || stateLock.tryLock();
        }
    
        @Override
        protected void releaseLock() {
            super.releaseLock();
            stateLock.unlock();
        }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 08:48:02 UTC 2023
    - 1.2K bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/RateLimiter.java

          long nowMicros = stopwatch.readMicros();
          if (!canAcquire(nowMicros, timeoutMicros)) {
            return false;
          } else {
            microsToWait = reserveAndGetWaitLength(permits, nowMicros);
          }
        }
        stopwatch.sleepMicrosUninterruptibly(microsToWait);
        return true;
      }
    
      private boolean canAcquire(long nowMicros, long timeoutMicros) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 18.2K bytes
    - Viewed (0)
  6. guava/src/com/google/common/util/concurrent/RateLimiter.java

          long nowMicros = stopwatch.readMicros();
          if (!canAcquire(nowMicros, timeoutMicros)) {
            return false;
          } else {
            microsToWait = reserveAndGetWaitLength(permits, nowMicros);
          }
        }
        stopwatch.sleepMicrosUninterruptibly(microsToWait);
        return true;
      }
    
      private boolean canAcquire(long nowMicros, long timeoutMicros) {
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Tue Apr 04 09:45:04 UTC 2023
    - 21.5K bytes
    - Viewed (0)
Back to top