- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for ResourceLock (0.38 sec)
-
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/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/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/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) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/AbstractWorkerLeaseServiceTest.groovy
return service } TestTrackedResourceLock resourceLock(String displayName, boolean locked, boolean hasLock = false) { return new TestTrackedResourceLock(displayName, coordinationService, Mock(ResourceLockContainer), locked, hasLock) } TestTrackedResourceLock resourceLock(String displayName) { return resourceLock(displayName, false) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 1.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLeaseRegistry.java
*/ ResourceLock getAllProjectsLock(Path buildIdentityPath); /** * Get a lock for access to the specified project's state. */ ResourceLock getProjectLock(Path buildIdentityPath, Path projectIdentityPath); /** * Get a lock for non-isolated tasks for the specified project. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 02:21:10 UTC 2024 - 5.4K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ResourceLockCoordinationService.java
/** * Adds a listener that is notified when a lock is released. Called while the state lock is held. */ void addLockReleaseListener(Action<ResourceLock> listener); void removeLockReleaseListener(Action<ResourceLock> listener);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 06:02:18 UTC 2024 - 2.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/api/services/internal/BuildServiceRegistryInternal.java
import org.gradle.api.services.BuildServiceParameters; import org.gradle.api.services.BuildServiceRegistration; import org.gradle.api.services.BuildServiceRegistry; import org.gradle.internal.resources.ResourceLock; import org.gradle.internal.resources.SharedResource; import org.gradle.internal.service.scopes.Scope; import org.gradle.internal.service.scopes.ServiceScope; import javax.annotation.Nullable; import java.util.List;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 20:25:05 UTC 2024 - 2.7K bytes - Viewed (0) -
staging/publishing/import-restrictions.yaml
- baseImportPath: "./staging/src/k8s.io/client-go/tools" excludeTests: true ignoredSubTrees: - "./staging/src/k8s.io/client-go/tools/cache/testing" - "./staging/src/k8s.io/client-go/tools/leaderelection/resourcelock" - "./staging/src/k8s.io/client-go/tools/portforward" - "./staging/src/k8s.io/client-go/tools/record" - "./staging/src/k8s.io/client-go/tools/events" - "./staging/src/k8s.io/client-go/tools/reference"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu May 30 13:13:22 UTC 2024 - 7.7K bytes - Viewed (0)