Skip to content

Commit bc0affb

Browse files
committed
Adjust thread count calculation in ChronicleRollingIssueTest for improved scalability
1 parent 7741ce6 commit bc0affb

1 file changed

Lines changed: 2 additions & 5 deletions

File tree

src/test/java/net/openhft/chronicle/queue/ChronicleRollingIssueTest.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -42,11 +42,8 @@ public void tearDown() {
4242

4343
@Test(timeout = 180_000L)
4444
public void test() throws InterruptedException {
45-
// Cap at 31 appenders. The old min(64, processors*4) - 1 formula started 63
46-
// appenders on large CI agents, all queueing on the same writeLock and each holding
47-
// it for mmap+EOF-probe work. This still exercises contention without scaling
48-
// pathologically with core count.
49-
int threads = Math.max(2, Math.min(32, Runtime.getRuntime().availableProcessors() * 2) - 1);
45+
int processors = Runtime.getRuntime().availableProcessors();
46+
int threads = Math.max(2, Math.min(64, processors * 2) - 1);
5047
int messages = 100;
5148

5249
AtomicInteger count = new AtomicInteger();

0 commit comments

Comments
 (0)