- Sort Score
- Result 10 results
- Languages All
Results 1 - 7 of 7 for workItem2 (0.14 sec)
-
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorParallelIntegrationTest.groovy
doLast { 6.times { i -> submitWorkItem("workItem\${i}") } } } """ // warm buildSrc succeeds("help") def calls = ["workItem0", "workItem1", "workItem2", "workItem3", "workItem4", "workItem5"] as String[] def handler = blockingHttpServer.expectConcurrentAndBlock(maxWorkers, calls)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 31.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/internal/work/DefaultAsyncWorkTracker.java
startWaiting(operation, workItems); waitForAll(operation, workItems, lockRetention); } private void waitForAll(BuildOperationRef operation, List<AsyncWorkCompletion> workItems, ProjectLockRetention lockRetention) { try { if (!workItems.isEmpty()) { waitForItemsAndGatherFailures(workItems, lockRetention);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6K bytes - Viewed (0) -
platforms/core-execution/workers/src/main/java/org/gradle/workers/internal/DefaultWorkerExecutor.java
private void await(List<AsyncWorkCompletion> workItems) throws WorkExecutionException { BuildOperationRef currentOperation = buildOperationRunner.getCurrentOperation(); try { if (CollectionUtils.any(workItems, workItem -> !workItem.isComplete())) { executionQueue.expand(); } asyncWorkTracker.waitForCompletion(currentOperation, workItems, RETAIN_PROJECT_LOCKS);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Mar 08 15:17:07 UTC 2024 - 15.2K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
WorkItem workItem = getNextItem(workerLease); if (workItem == null) { break; } Object selected = workItem.selection.getItem(); LOGGER.info("{} ({}) started.", selected, Thread.currentThread()); execute(selected, workItem.plan, workItem.executor); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0) -
pilot/pkg/autoregistration/controller.go
if err != nil { autoRegistrationErrors.Increment() return err } if !changed { return nil } log.Infof("updated auto-registered WorkloadEntry %s/%s as disconnected", workItem.proxy.Metadata.Namespace, workItem.entryName) if workItem.autoCreated { autoRegistrationUnregistrations.Increment() }
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 16 00:00:36 UTC 2024 - 26.4K bytes - Viewed (0) -
pkg/controller/tainteviction/timed_workers.go
return &WorkArgs{ NamespacedName: types.NamespacedName{Namespace: namespace, Name: name}, } } // TimedWorker is a responsible for executing a function no earlier than at FireAt time. type TimedWorker struct { WorkItem *WorkArgs CreatedAt time.Time FireAt time.Time Timer clock.Timer } // createWorker creates a TimedWorker that will execute `f` not earlier than `fireAt`.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Oct 30 12:23:56 UTC 2023 - 4.8K bytes - Viewed (0) -
platforms/ide/tooling-api/src/testFixtures/groovy/org/gradle/integtests/tooling/fixture/ProgressEvents.groovy
} boolean isDownload() { return descriptor instanceof FileDownloadOperationDescriptor } boolean isBuildOperation() { return !test && !task && !workItem && !projectConfiguration && !transform } void assertIsTask() { assert startEvent instanceof TaskStartEvent assert finishEvent instanceof TaskFinishEvent
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Feb 23 13:50:05 UTC 2024 - 21.9K bytes - Viewed (0)