fix: fix test for machines with 2 or less available processors.

tomtom-international · Nov 12, 2019 · 48b4a8a · 48b4a8a
1 parent aec5c19
commit 48b4a8a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/james-agent/src/test/groovy/com/tomtom/james/publisher/DisruptorAsyncPublisherSpec.groovy b/james-agent/src/test/groovy/com/tomtom/james/publisher/DisruptorAsyncPublisherSpec.groovy
@@ -18,7 +18,7 @@ class DisruptorAsyncPublisherSpec extends Specification {
 
     private final int WORKER_COUNT = 2
 
-    private int PUBLISHER_SIZE = Runtime.getRuntime().availableProcessors() - WORKER_COUNT
+    private int PUBLISHER_SIZE = Math.max(2 * WORKER_COUNT, Runtime.getRuntime().availableProcessors() - WORKER_COUNT)
 
     ExecutorService eventCreator = Executors.newFixedThreadPool(PUBLISHER_SIZE)
     CountingPublisher sleepingPublisher = new CountingPublisher( { it-> sleep(10)})