- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for SimpleWorker (0.2 sec)
-
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationExecutorParallelExecutionTest.groovy
outerOperationCompletion = workerRegistry.startWorker() outerOperation = workerRegistry.getCurrentWorkerLease() } static class SimpleWorker implements BuildOperationWorker<DefaultBuildOperationQueueTest.TestBuildOperation> { void execute(DefaultBuildOperationQueueTest.TestBuildOperation run, BuildOperationContext context) { run.run(context) } }
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/test/groovy/org/gradle/internal/operations/MaxWorkersTest.groovy
given: def maxWorkers = 1 def workerLeaseService = this.workerLeaseService(maxWorkers) def processor = createProcessor(workerLeaseService, maxWorkers) def processorWorker = new SimpleWorker() when: async { start { def cl = workerLeaseService.startWorker() instant.worker1 thread.blockUntil.worker2Ready
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 8.3K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/DefaultBuildOperationQueueTest.groovy
static class Failure extends TestBuildOperation { void run(BuildOperationContext buildOperationContext) { throw new BuildOperationFailure(this, "always fails") } } static class SimpleWorker implements BuildOperationQueue.QueueWorker<TestBuildOperation> { void execute(TestBuildOperation run) { run.run(null) } String getDisplayName() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 9.4K bytes - Viewed (0)