- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 32 for MaxWorkers (0.14 sec)
-
subprojects/composite-builds/src/integTest/groovy/org/gradle/integtests/composite/CompositeBuildParallelIntegrationTest.groovy
""" } } expect: execute(buildA, "delegate", "--parallel", "--max-workers=$maxWorkers") operations.assertConcurrentOperationsDoNotExceed(ExecuteTaskBuildOperationType, maxWorkers, maxWorkers != 1) where: maxWorkers << [ 1, 2, 4 ] } def "can build transitive dependency chain with --max-workers == 1"() { def previousBuild = buildA
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 01 03:07:53 UTC 2023 - 4.3K bytes - Viewed (0) -
subprojects/core/src/test/groovy/org/gradle/internal/operations/MaxWorkersTest.groovy
CountDownLatch leaseAcquiredLatch = new CountDownLatch(maxWorkers) CountDownLatch runningLatch = new CountDownLatch(maxWorkers) CountDownLatch fullyUtilizedLatch = new CountDownLatch(1) final Object release = new Object() def workerLeaseService = this.workerLeaseService(maxWorkers)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 8.3K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultConditionalExecutionQueueTest.groovy
} def "can process more executions than max workers (maxWorkers = #maxWorkers)"() { def executions = [] queue = new DefaultConditionalExecutionQueue(DISPLAY_NAME, new DefaultWorkerLimits(maxWorkers), new DefaultExecutorFactory(), workerLeaseService) expect: async { start { int executionCount = maxWorkers * 3 executionCount.times { i ->
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 6.9K bytes - Viewed (0) -
platforms/enterprise/enterprise-plugin-performance/src/templates/root/gradle.properties
<% if (binding.hasVariable("parallel")) { %>org.gradle.parallel=true<% } %>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Jul 17 10:38:06 UTC 2023 - 349 bytes - Viewed (0) -
testing/performance/src/templates/project-with-source/gradle.properties
<% if (binding.hasVariable("parallel")) { %>org.gradle.parallel=true<% } %> <% if (binding.hasVariable("maxWorkers")) { %>org.gradle.workers.max=${binding.getVariable("maxWorkers")}<% } %> compilerMemory=<% if (binding.hasVariable("compilerMemory")) { %>${binding.getVariable("compilerMemory")}<% } else { %>1g<% } %>
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 742 bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorNestingIntegrationTest.groovy
def "workers with no isolation can spawn more than max workers items of work"() { def maxWorkers = 4 buildFile << """ ${getWorkActionWithNesting("noIsolation", "noIsolation")} task runInWorker(type: NestingWorkerTask) { submissions = ${maxWorkers * 2} childSubmissions = ${maxWorkers} } """.stripIndent() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:36:27 UTC 2023 - 9.5K bytes - Viewed (0) -
platforms/core-execution/workers/src/integTest/groovy/org/gradle/workers/internal/WorkerExecutorParallelIntegrationTest.groovy
def calls = ["workItem0", "workItem1", "workItem2", "workItem3", "workItem4", "workItem5"] as String[] def handler = blockingHttpServer.expectConcurrentAndBlock(maxWorkers, calls) when: args("--max-workers=${maxWorkers}") executer.withTasks("parallelWorkTask") def gradle = executer.start() then: handler.waitForAllPendingCalls() when:
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Oct 24 06:54:47 UTC 2023 - 31.7K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/AbstractWorkerLeaseServiceTest.groovy
WorkerLeaseService workerLeaseService(int maxWorkers) { return workerLeaseService(true, maxWorkers) } WorkerLeaseService workerLeaseService(boolean parallel, int maxWorkers = 1) { def service = new DefaultWorkerLeaseService(coordinationService, new DefaultWorkerLimits(maxWorkers)) service.startProjectExecution(parallel) return service }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 1.8K bytes - Viewed (0) -
pilot/pkg/status/resourcelock.go
workerCount uint // maximum worker routine count maxWorkers uint currentlyWorking sets.Set[lockResource] lock sync.Mutex } func NewWorkerPool(write func(*config.Config, any), get func(Resource) *config.Config, maxWorkers uint) WorkerQueue { return &WorkerPool{ write: write, get: get, maxWorkers: maxWorkers, currentlyWorking: sets.New[lockResource](),
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sun Feb 04 03:39:42 UTC 2024 - 6.4K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testng/TestNGFailFastIntegrationTest.groovy
class TestNGFailFastIntegrationTest extends AbstractJvmFailFastIntegrationSpec implements TestNGMultiVersionTest { def "parallel #parallel execution with #threadCount threads, #maxWorkers workers fails fast"() { given: buildFile.text = generator.initBuildFile(maxWorkers) buildFile << """ test { useTestNG() { parallel = '$parallel' threadCount = $threadCount
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 2.7K bytes - Viewed (0)