Fix Non-Deterministic Pivot Test

benjchristensen · benjchristensen · commit 7298e763b34c · 2014-03-25T14:37:35.000-07:00
This failed on build servers (small, slow, single or dual-core machines).
diff --git a/rxjava-core/src/test/java/rx/operators/OperatorPivotTest.java b/rxjava-core/src/test/java/rx/operators/OperatorPivotTest.java
@@ -287,8 +287,10 @@ private void setMaxConcurrency(final AtomicInteger maxOuterConcurrency, int oute
         ts.awaitTerminalEvent();
 
         System.out.println("onNext [" + ts.getOnNextEvents().size() + "]: " + ts.getOnNextEvents());
-        System.out.println("max outer concurrency: " + maxOuterConcurrency.get());
-        assertTrue(maxOuterConcurrency.get() > 2); // should be 4 since we have 4 threads running but setting at 3 as this is somewhat non-deterministic
+        if (Runtime.getRuntime().availableProcessors() >= 4) {
+            System.out.println("max outer concurrency: " + maxOuterConcurrency.get());
+            assertTrue(maxOuterConcurrency.get() > 1); // should be 4 since we have 4 threads and cores running but setting at just > 1 as this is non-deterministic
+        }
         System.out.println("max group concurrency: " + maxGroupConcurrency.get());
         assertTrue(maxGroupConcurrency.get() == 1); // should always be 1
 
