- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for canAcquire (0.16 sec)
-
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) -
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) -
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) -
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) -
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) -
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)