- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 11 for acquireLock (0.37 sec)
-
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) -
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
for (LockGraphNode acquiredLock : acquiredLocks) { checkAcquiredLock(policy, acquiredLock); } } /** * Checks the acquisition-ordering between {@code this}, which is about to be acquired, and the * specified {@code acquiredLock}. * * <p>When this method returns, the {@code acquiredLock} should be in either the {@code
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
for (LockGraphNode acquiredLock : acquiredLocks) { checkAcquiredLock(policy, acquiredLock); } } /** * Checks the acquisition-ordering between {@code this}, which is about to be acquired, and the * specified {@code acquiredLock}. * * <p>When this method returns, the {@code acquiredLock} should be in either the {@code
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/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) -
test-site/activator-launch-1.3.2.jar
private long timeout; private java.util.Map currentLockCounters; protected void FileBasedLockStrateg(); protected void FileBasedLockStrateg(boolean); private void FileBasedLockStrateg(FileBasedLockStrateg$FileLocker, boolean); protected final boolean acquireLock(java.io.File); protected final void releaseLock(java.io.File); private static void debugLocking(String); private int incrementLock(java.io.File); } org/apache/ivy/plugins/lock/FileBasedLockStrateg$FileLocker.class package org.apache.ivy.plugins.lock;...
Registered: Wed Jun 12 15:38:08 UTC 2024 - Last Modified: Mon Apr 20 08:41:37 UTC 2015 - 1.2M bytes - Viewed (1)