- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for threadCount (0.17 sec)
-
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testng/TestNGFailFastIntegrationTest.groovy
def "parallel #parallel execution with #threadCount threads, #maxWorkers workers fails fast"() { given: buildFile.text = generator.initBuildFile(maxWorkers) buildFile << """ test { useTestNG() { parallel = '$parallel' threadCount = $threadCount } } """.stripIndent()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 2.7K bytes - Viewed (0) -
src/runtime/testdata/testprogcgo/stack_windows.go
if err != nil { return 0, err } return m.PagefileUsage, nil } func StackMemory() { mem1, err := getPagefileUsage() if err != nil { panic(err) } const threadCount = 100 var wg sync.WaitGroup for i := 0; i < threadCount; i++ { wg.Add(1) go func() { runtime.LockOSThread() wg.Done() select {} }() } wg.Wait() mem2, err := getPagefileUsage() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 23 17:31:31 UTC 2023 - 1.1K bytes - Viewed (0) -
samples/crawler/src/main/java/okhttp3/sample/Crawler.java
public Crawler(OkHttpClient client) { this.client = client; } private void parallelDrainQueue(int threadCount) { ExecutorService executor = Executors.newFixedThreadPool(threadCount); for (int i = 0; i < threadCount; i++) { executor.execute(() -> { try { drainQueue(); } catch (Exception e) { e.printStackTrace(); }
Registered: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 4.6K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/integTest/groovy/org/gradle/internal/SystemPropertiesIntegrationTest.groovy
assert System.getProperty(notsetPropertyName) == null } def "withProperty and withProperties are never run concurrently"() { final int threadCount = 100 def id = UUID.randomUUID().toString() when: async { threadCount.times { i -> start { SystemProperties.instance.withSystemProperty(id, "bar", {"baz"}) } start {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 4.1K bytes - Viewed (0) -
platforms/jvm/testing-jvm-infrastructure/src/main/java/org/gradle/api/internal/tasks/testing/testng/TestNGSpec.java
boolean isDryRun ) { this.filter = filter; this.defaultSuiteName = defaultSuiteName; this.defaultTestName = defaultTestName; this.parallel = parallel; this.threadCount = threadCount; this.suiteThreadPoolSize = suiteThreadPoolSize; this.useDefaultListener = useDefaultListener; this.threadPoolFactoryClass = threadPoolFactoryClass; this.includeGroups = includeGroups;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Sat May 18 12:30:10 UTC 2024 - 3.8K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/work/DefaultWorkerLeaseServiceProjectLockTest.groovy
assert workerLeaseService.currentProjectLocks.empty } def "multiple threads can coordinate locking of a project"() { def threadCount = 10 def started = new CountDownLatch(threadCount) when: async { threadCount.times { start { started.countDown() thread.blockUntil.releaseAll
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 05 16:29:26 UTC 2024 - 25.6K bytes - Viewed (0) -
src/runtime/testdata/testprog/syscall_windows.go
if err != nil { return 0, err } return m.PagefileUsage, nil } func StackMemory() { mem1, err := getPagefileUsage() if err != nil { panic(err) } const threadCount = 100 var wg sync.WaitGroup for i := 0; i < threadCount; i++ { wg.Add(1) go func() { runtime.LockOSThread() wg.Done() select {} }() } wg.Wait() mem2, err := getPagefileUsage() if err != nil {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Oct 23 17:31:31 UTC 2023 - 1.5K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/test/groovy/org/gradle/api/tasks/testing/testng/TestNGOptionsTest.groovy
excludeGroups == source.excludeGroups configFailurePolicy == source.configFailurePolicy listeners == source.listeners parallel == source.parallel threadCount == source.threadCount suiteThreadPoolSize.get() == source.suiteThreadPoolSize.get() useDefaultListeners == source.useDefaultListeners threadPoolFactoryClass == source.threadPoolFactoryClass
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jun 07 22:42:49 UTC 2024 - 4K bytes - Viewed (0) -
platforms/core-runtime/base-services/src/test/groovy/org/gradle/internal/resources/SharedResourceLeaseRegistryTest.groovy
given: sharedResourceLeaseRegistry.registerSharedResource('resource', 1) def threadCount = 10 def started = new CountDownLatch(threadCount) when: async { threadCount.times { start { started.countDown() thread.blockUntil.releaseAll
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 08:48:02 UTC 2023 - 5K bytes - Viewed (0) -
platforms/jvm/testing-jvm/src/integTest/groovy/org/gradle/testing/testng/TestNGParallelSuiteIntegrationTest.groovy
} test { useTestNG { suites "suite.xml" } } """ } def createTests(int testCount, int threadCount) { String suiteXml = "" testCount.times { x -> file("src/test/java/Foo${x}Test.java") << """ public class Foo${x}Test {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Sep 18 20:52:40 UTC 2023 - 3K bytes - Viewed (0)