- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 10 for acquireLocks (1.38 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultResourceLockCoordinationService.java
return unlock(Arrays.asList(resourceLocks)); } private static class AcquireLocks implements InternalTransformer<ResourceLockState.Disposition, ResourceLockState> { private final Iterable<? extends ResourceLock> resourceLocks; private final boolean blocking; AcquireLocks(Iterable<? extends ResourceLock> resourceLocks, boolean blocking) { this.resourceLocks = resourceLocks;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 17:16:10 UTC 2024 - 11.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
} } private void releaseLocks(Iterable<? extends ResourceLock> locks) { coordinationService.withStateLock(unlock(locks)); } private void acquireLocks(final Iterable<? extends ResourceLock> locks) { if (containsProjectLocks(locks)) { projectLockStatistics.measure(new Runnable() { @Override public void run() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* result in corrupting the acquireLocks set. */ private static void lockStateChanged(CycleDetectingLock lock) { if (!lock.isAcquiredByCurrentThread()) { // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get ArrayList<LockGraphNode> acquiredLockList = requireNonNull(acquiredLocks.get()); LockGraphNode node = lock.getLockGraphNode();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 35.9K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
* result in corrupting the acquireLocks set. */ private static void lockStateChanged(CycleDetectingLock lock) { if (!lock.isAcquiredByCurrentThread()) { // requireNonNull accommodates Android's @RecentlyNullable annotation on ThreadLocal.get ArrayList<LockGraphNode> acquiredLockList = requireNonNull(acquiredLocks.get()); LockGraphNode node = lock.getLockGraphNode();
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Dec 15 19:31:54 UTC 2023 - 35.9K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/AbstractTrackedResourceLock.java
public String toString() { return getClass().getSimpleName() + " " + getDisplayName(); } @Override public boolean tryLock() { if (!isLockedByCurrentThread()) { if (acquireLock()) { LOGGER.debug("{}: acquired lock on {}", Thread.currentThread().getName(), displayName); try { owner.lockAcquired(this); } catch (RuntimeException e) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/DefaultLease.java
return ownerThread != null; } @Override protected boolean doIsLockedByCurrentThread() { return Thread.currentThread() == ownerThread; } @Override protected boolean acquireLock() { if (parent.grantLease()) { ownerThread = Thread.currentThread(); } return ownerThread != null; } @Override protected void releaseLock() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ExclusiveAccessResourceLock.java
super(displayName, coordinationService, owner); } @Override protected boolean acquireLock() { Thread currentThread = Thread.currentThread(); if (owner == currentThread) { return true; } if (owner == null && canAcquire()) { owner = currentThread;
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/test/groovy/org/gradle/internal/resources/TestTrackedResourceLock.groovy
return lockedState.get() } @Override boolean doIsLockedByCurrentThread() { return owner.get() == Thread.currentThread() } @Override protected boolean acquireLock() { if (!lockedState.get()) { owner.set(Thread.currentThread()) lockedState.set(true) return true } else { return false } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/model/CalculatedValueContainer.java
this.defaultContext = defaultContext; } // Can be called multiple times void attachValue(CalculatedValueContainer<T, ?> owner, @Nullable NodeExecutionContext context) { acquireLock(); try { if (done) { // Already calculated return; } done = true;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 18 08:26:19 UTC 2024 - 10.3K bytes - Viewed (0) -
testing/architecture-test/src/changes/archunit-store/internal-api-nullability.txt
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 11 09:51:15 UTC 2024 - 967.9K bytes - Viewed (0)