- Sort Score
- Result 10 results
- Languages All
Results 1 - 9 of 9 for selectNext (0.24 sec)
-
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultPlanExecutorTest.groovy
then: 1 * cancellationHandler.isCancellationRequested() >> false 1 * workerLease.tryLock() >> true 1 * workSource.executionState() >> WorkSource.State.MaybeWorkReadyToStart 1 * workSource.selectNext() >> WorkSource.Selection.of(node) 1 * worker.execute(node) 1 * workSource.finishedExecuting(node, null) then: 1 * cancellationHandler.isCancellationRequested() >> false
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/WorkSource.java
public interface WorkSource<T> { enum State { /** * There may be work ready to start. The worker thread should call {@link #selectNext()} to select the next item. * Note this does not mean that {@link #selectNext()} will necessarily return an item, only that it is likely to. * {@link #selectNext()} may not return an item, for example when some other worker thread takes the work. */ MaybeWorkReadyToStart,
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sun Nov 13 20:53:27 UTC 2022 - 7.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
} public WorkSource.Selection<WorkItem> selectNext() { coordinationService.assertHasStateLock(); Iterator<PlanDetails> iterator = queues.iterator(); while (iterator.hasNext()) { PlanDetails details = iterator.next(); WorkSource.Selection<Object> selection = details.source.selectNext(); if (selection.isNoMoreWorkToStart()) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/execution/plan/DefaultExecutionPlanParallelTest.groovy
assert finalizedPlan.selectNext().noWorkReadyToStart assert finalizedPlan.executionState() == WorkSource.State.NoWorkReadyToStart } } void assertNoWorkReadyToStartAfterSelect() { coordinator.withStateLock { // In some cases, a call to selectNext() is required to calculate that nothing is ready
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 93.5K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultFinalizedExecutionPlan.java
} } else { visitor.accept(node); visited.add(node); } } } @Override public Selection<Node> selectNext() { lockCoordinator.assertHasStateLock(); if (waitingToStartNodes.isEmpty()) { return Selection.noMoreWorkToStart(); } if (readyNodes.isEmpty() || !maybeNodesSelectable) {
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/test/groovy/org/gradle/execution/plan/DefaultExecutionPlanTest.groovy
assert finalizedPlan.executionState() == WorkSource.State.MaybeWorkReadyToStart // There should always be a node ready to start when executing sequentially def selection = finalizedPlan.selectNext() if (selection.noMoreWorkToStart) { break }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 05 22:18:26 UTC 2024 - 35.5K bytes - Viewed (0) -
platforms/software/dependency-management/src/test/groovy/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/selectors/SelectorStateResolverTest.groovy
when: conflictHandlingResolver.selectBest(moduleId, moduleSelectors([missingLow])) then: thrown(ModuleVersionResolveException) when: conflictHandlingResolver.selectBest(moduleId, moduleSelectors([missingLow, missingHigh])) then: thrown(ModuleVersionResolveException)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Feb 07 23:54:34 UTC 2024 - 16.8K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/selectors/SelectorStateResolver.java
this.resolveOptimizations = resolveOptimizations; this.versionComparator = versionComparator; this.versionParser = versionParser; } public T selectBest(ModuleIdentifier moduleId, ModuleSelectors<? extends ResolvableSelectorState> selectors) { VersionSelector allRejects = createAllRejects(selectors); List<T> candidates = resolveSelectors(selectors, allRejects);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Dec 15 14:22:29 UTC 2023 - 12.2K bytes - Viewed (0) -
platforms/software/dependency-management/src/main/java/org/gradle/api/internal/artifacts/ivyservice/resolveengine/graph/builder/ModuleResolveState.java
// Selection deferred as we know another selector will be added soon return; } ComponentState newSelected = selectorStateResolver.selectBest(getId(), selectors); newSelected.setSelectors(selectors); if (selected == null) { // In some cases we should ignore this because the selection happens to be a known conflict
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 02:21:08 UTC 2024 - 18.7K bytes - Viewed (0)