- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for currentWorkerLease (0.14 sec)
-
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceWorkerLeaseTest.groovy
assert registry.workerThread def lease = registry.currentWorkerLease def nested = registry.runAsWorkerThread({ assert registry.workerThread assert registry.currentWorkerLease == lease "result" } as Factory) assert registry.workerThread assert registry.currentWorkerLease == lease nested } as Factory
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 13.2K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/work/DefaultAsyncWorkTrackerTest.groovy
void cancel() { } }) asyncWorkTracker.waitForCompletion(operation1, RELEASE_AND_REACQUIRE_PROJECT_LOCKS) then: _ * workerLeaseService.currentWorkerLease >> workerLease 1 * workerLeaseService.runAsIsolatedTask(_) >> { Runnable runnable -> runnable.run() } 1 * workerLeaseService.withoutLock(workerLease, _) >> { locks, Runnable runnable -> runnable.run() }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Jun 06 04:53:10 UTC 2023 - 14.9K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/execution/plan/DefaultPlanExecutor.java
WorkerLease currentWorkerLease = workerLeaseService.getCurrentWorkerLease(); MergedQueues thisPlanOnly = new MergedQueues(coordinationService, true); thisPlanOnly.add(planDetails); new ExecutorWorker(thisPlanOnly, currentWorkerLease, cancellationToken, coordinationService, workerLeaseService, stats).run();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 29.1K bytes - Viewed (0)