8081734: ConcurrentHashMap/ConcurrentAssociateTest.java, times out 90% of time on sparc with 256 cpu.

SendaoYan · jerboaa · commit 35d219b4d486 · 2025-07-08T08:36:55.000Z
Backport-of: 6e48caf2507d4a45e1861ee699a32a5e459d70c2
diff --git a/jdk/test/java/util/concurrent/ConcurrentHashMap/ConcurrentAssociateTest.java b/jdk/test/java/util/concurrent/ConcurrentHashMap/ConcurrentAssociateTest.java
@@ -120,7 +120,8 @@ private static void testOnce(String desc, BiConsumer<ConcurrentMap<Object, Objec
             }
         };
 
-        int ps = Runtime.getRuntime().availableProcessors();
+        // Bound concurrency to avoid degenerate performance
+        int ps = Math.min(Runtime.getRuntime().availableProcessors(), 32);
         Stream<CompletableFuture> runners = IntStream.range(0, ps)
                 .mapToObj(i -> sr.get())
                 .map(CompletableFuture::runAsync);

Original file line number	Diff line number	Diff line change
`@@ -120,7 +120,8 @@ private static void testOnce(String desc, BiConsumer<ConcurrentMap<Object, Objec`
`120`	`120`	`}`
`121`	`121`	`};`
`122`	`122`
`123`		`- int ps = Runtime.getRuntime().availableProcessors();`
	`123`	`+ // Bound concurrency to avoid degenerate performance`
	`124`	`+ int ps = Math.min(Runtime.getRuntime().availableProcessors(), 32);`
`124`	`125`	`Stream<CompletableFuture> runners = IntStream.range(0, ps)`
`125`	`126`	`.mapToObj(i -> sr.get())`
`126`	`127`	`.map(CompletableFuture::runAsync);`