- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 33 for ResourceLock (0.18 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLock.java
* outside of a {@link ResourceLockCoordinationService#withStateLock(Transformer)} transform. */ public interface ResourceLock extends Describable { /** * Returns true if this resource is locked by any thread. * * @return true if any thread holds the lock for this resource */ boolean isLocked(); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 1.6K bytes - Viewed (0) -
pilot/pkg/status/resourcelock.go
John Howard <******@****.***> 1707017982 -0800
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/work/TestWorkerLeaseService.groovy
@Override void withoutLocks(Collection<? extends ResourceLock> locks, Runnable action) { action.run() } @Override void withoutLock(ResourceLock lock, Runnable action) { action.run() } @Override <T> T withReplacedLocks(Collection<? extends ResourceLock> currentLocks, ResourceLock newLock, Factory<T> factory) { return factory.create() } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/AbstractResourceLockRegistry.java
} } @Override public boolean hasOpenLocks() { for (ResourceLock resourceLock : resourceLocks.values()) { if (resourceLock.isLocked()) { return true; } } return false; } @Override public void lockAcquired(ResourceLock resourceLock) { ThreadLockDetails<T> lockDetails = detailsForCurrentThread();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerLeaseService.java
*/ <T> T withLocks(Collection<? extends ResourceLock> locks, Factory<T> factory); /** * Runs a given {@link Runnable} while the specified locks are being held, releasing * the locks upon completion. Blocks until the specified locks can be obtained. */ void withLocks(Collection<? extends ResourceLock> locks, Runnable runnable); /**
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 3.4K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/WorkerLeaseRegistry.java
*/ WorkerLease getCurrentWorkerLease(); /** * Creates a new {@link ResourceLock} that can be used to reserve a worker lease. Note that this does not actually reserve a lease, * it simply creates a {@link ResourceLock} representing the worker lease. The worker lease can be reserved only when
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/ExclusiveAccessResourceLockTest.groovy
when: coordinationService.withStateLock(tryLock(resourceLock)) then: resourceLock.doIsLocked() resourceLock.doIsLockedByCurrentThread() when: coordinationService.withStateLock(unlock(resourceLock)) then: !resourceLock.doIsLocked() !resourceLock.doIsLockedByCurrentThread() }
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/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceTest.groovy
def workerLeaseService = workerLeaseService(1) def "can use withLocks to execute a runnable with resources locked"() { boolean executed = false def lock1 = resourceLock("lock1", false) def lock2 = resourceLock("lock1", false) when: workerLeaseService.withLocks([lock1, lock2], runnable { assert lock1.lockedState assert lock2.lockedState
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 4.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockContainer.java
* limitations under the License. */ package org.gradle.internal.resources; public interface ResourceLockContainer { void lockAcquired(ResourceLock lock); void lockReleased(ResourceLock lock);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 785 bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockState.java
* fails. */ void registerLocked(ResourceLock resourceLock); /** * Registers a resource lock that has been unlocked during the transform so that the coordination service can * notify threads waiting on a lock. */ void registerUnlocked(ResourceLock resourceLock); /** * Release any locks that have been acquired during the transform. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 06:47:40 UTC 2024 - 1.3K bytes - Viewed (0)