- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 33 for ResourceLock (0.16 sec)
-
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/SharedResourceLeaseRegistry.java
*/ package org.gradle.internal.resources; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; public class SharedResourceLeaseRegistry extends AbstractResourceLockRegistry<String, ResourceLock> { private final Map<String, LeaseHolder> sharedResources = new ConcurrentHashMap<String, LeaseHolder>(); private final ResourceLockCoordinationService coordinationService;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/resources/ProjectLock.java
*/ package org.gradle.internal.resources; public class ProjectLock extends ExclusiveAccessResourceLock { private final ResourceLock allProjectsLock; public ProjectLock(String displayName, ResourceLockCoordinationService coordinationService, ResourceLockContainer owner, ResourceLock allProjectsLock) { super(displayName, coordinationService, owner); this.allProjectsLock = allProjectsLock; }
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/TaskExecutionLockRegistry.java
super(coordinationService); this.projectLockRegistry = projectLockRegistry; } public ResourceLock getTaskExecutionLock(Path buildIdentityPath, final Path projectIdentityPath) { if (projectLockRegistry.getAllowsParallelExecution()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.7K 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/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy
} boolean lockIsHeld(final ResourceLock resourceLock) { MutableBoolean held = new MutableBoolean() coordinationService.withStateLock(new InternalTransformer<ResourceLockState.Disposition, ResourceLockState>() { @Override ResourceLockState.Disposition transform(ResourceLockState resourceLockState) { held.set(resourceLock.locked && resourceLock.isLockedByCurrentThread())
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/AbstractResourceLockRegistryTest.groovy
static class TestRegistry extends AbstractResourceLockRegistry<String, ResourceLock> { TestRegistry(ResourceLockCoordinationService coordinationService) { super(coordinationService) } def getResourceLock(String displayName) { return getOrRegisterResourceLock(displayName, new AbstractResourceLockRegistry.ResourceLockProducer<String, ResourceLock>() { @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 2.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/ActionNode.java
import org.gradle.api.internal.tasks.NodeExecutionContext; import org.gradle.api.internal.tasks.TaskDependencyContainer; import org.gradle.api.internal.tasks.WorkNodeAction; import org.gradle.internal.resources.ResourceLock; import javax.annotation.Nullable; import java.util.List; import java.util.function.Consumer; public class ActionNode extends Node implements SelfExecutingNode { private WorkNodeAction action;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Aug 26 20:11:12 UTC 2022 - 3.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/TaskInAnotherBuild.java
import org.gradle.composite.internal.IncludedBuildTaskResource; import org.gradle.composite.internal.TaskIdentifier; import org.gradle.internal.lazy.Lazy; import org.gradle.internal.resources.ResourceLock; import org.gradle.util.Path; import javax.annotation.Nullable; import java.util.Collections; import java.util.List; import java.util.Set;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 06 15:09:14 UTC 2023 - 7.1K 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)