- Sort Score
- Result 10 results
- Languages All
Results 1 - 6 of 6 for WorkerLease (0.16 sec)
-
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultPlanExecutorTest.groovy
def cancellationHandler = Mock(BuildCancellationToken) def coordinationService = new DefaultResourceLockCoordinationService() def workerLeaseService = Mock(WorkerLeaseService) def workerLease = Mock(WorkerLeaseRegistry.WorkerLease) def executor = new DefaultPlanExecutor(new DefaultWorkerLimits(1), executorFactory, workerLeaseService, cancellationHandler, coordinationService, new DefaultInternalOptions([:]))
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 4.3K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
private void awaitCompletion(WorkSource<?> workSource, WorkerLease workerLease, Collection<? super Throwable> failures) { coordinationService.withStateLock(resourceLockState -> { if (workSource.allExecutionComplete()) { // Need to hold a worker lease in order to finish up if (!workerLease.isLockedByCurrentThread()) { if (!workerLease.tryLock()) { return RETRY;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
start { def workerLease = workerLeaseService.newWorkerLease() coordinationService.withStateLock(lock(workerLease)) try { instant.worker2Executed } finally { coordinationService.withStateLock(unlock(workerLease)) } }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/main/java/org/gradle/internal/work/DefaultWorkerLeaseService.java
} } @Override public int getMaxWorkerCount() { return workerLimits.getMaxWorkerCount(); } @Override public WorkerLease getCurrentWorkerLease() { List<? extends WorkerLease> operations = workerLeaseLockRegistry.getResourceLocksByCurrentThread(); if (operations.isEmpty()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 09 04:43:28 UTC 2024 - 20.9K bytes - Viewed (0) -
platforms/extensibility/unit-test-fixtures/src/main/java/org/gradle/testfixtures/internal/ProjectBuilderImpl.java
WorkerLeaseService workerLeaseService = buildServices.get(WorkerLeaseService.class); WorkerLeaseRegistry.WorkerLeaseCompletion workerLease = workerLeaseService.maybeStartWorker(); buildServices.get(ProjectParallelExecutionController.class).startProjectExecution(false); GradleInternal gradle = build.getMutableModel();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:36 UTC 2024 - 15.7K bytes - Viewed (0) -
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)