- Sort Score
- Result 10 results
- Languages All
Results 11 - 14 of 14 for workerLease (0.16 sec)
-
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationExecutorParallelExecutionTest.groovy
WorkerLeaseService workerRegistry BuildOperationExecutor buildOperationExecutor WorkerLeaseRegistry.WorkerLeaseCompletion outerOperationCompletion WorkerLeaseRegistry.WorkerLease outerOperation def setupBuildOperationExecutor(int maxThreads) { def workerLimits = new DefaultWorkerLimits(maxThreads)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.6K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultFinalizedExecutionPlan.java
runningNodes.clear(); reachableCache.clear(); } private void resourceUnlocked(ResourceLock resourceLock) { if (!(resourceLock instanceof WorkerLeaseRegistry.WorkerLease) && !readyNodes.isEmpty()) { maybeNodesSelectable = true; } } @Override public State executionState() { lockCoordinator.assertHasStateLock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Dec 28 21:49:39 UTC 2022 - 28.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/operations/DefaultBuildOperationQueue.java
DefaultBuildOperationQueue(boolean allowAccessToProjectState, WorkerLeaseService workerLeases, Executor executor, QueueWorker<T> queueWorker) { this.allowAccessToProjectState = allowAccessToProjectState; this.workerLeases = workerLeases; this.executor = executor; this.queueWorker = queueWorker; } @Override
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jan 31 15:18:20 UTC 2023 - 10.4K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/taskgraph/DefaultTaskExecutionGraphSpec.groovy
def buildOperationRunner = new TestBuildOperationRunner() def listenerBuildOperationDecorator = new TestListenerBuildOperationDecorator() def workerLimits = new DefaultWorkerLimits(1) def workerLeases = new DefaultWorkerLeaseService(coordinator, workerLimits) def executorFactory = Mock(ExecutorFactory) def accessHierarchies = new ExecutionNodeAccessHierarchies(CASE_SENSITIVE, Stub(Stat))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 20.6K bytes - Viewed (0)