Performance Testing

Author: benjchristensen

rxjava-core/src/perf/java/rx/ObservableCreatePerformance.java

@@ -7,6 +7,10 @@
 
 public class ObservableCreatePerformance extends AbstractPerformanceTester {
 
+    ObservableCreatePerformance() {
+        super(REPETITIONS);
+    }
+
     public static void main(String args[]) {
 
         final ObservableCreatePerformance spt = new ObservableCreatePerformance();

rxjava-core/src/perf/java/rx/operators/OperatorFromIterablePerformance.java

@@ -11,6 +11,10 @@
 
 public class OperatorFromIterablePerformance extends AbstractPerformanceTester {
 
+    OperatorFromIterablePerformance() {
+        super(REPETITIONS);
+    }
+    
     public static void main(String args[]) {
 
         final OperatorFromIterablePerformance spt = new OperatorFromIterablePerformance();

rxjava-core/src/perf/java/rx/operators/OperatorMapPerformance.java

@@ -8,6 +8,10 @@
 
 public class OperatorMapPerformance extends AbstractPerformanceTester {
 
+    OperatorMapPerformance() {
+        super(REPETITIONS);
+    }
+    
     public static void main(String args[]) {
 
         final OperatorMapPerformance spt = new OperatorMapPerformance();

rxjava-core/src/perf/java/rx/operators/OperatorMergePerformance.java

@@ -9,6 +9,10 @@
 
 public class OperatorMergePerformance extends AbstractPerformanceTester {
 
+    OperatorMergePerformance() {
+        super(REPETITIONS);
+    }
+    
     public static void main(String args[]) {
 
         final OperatorMergePerformance spt = new OperatorMergePerformance();

rxjava-core/src/perf/java/rx/operators/OperatorObserveOnPerformance.java

@@ -0,0 +1,46 @@
+package rx.operators;
+
+import rx.Observable;
+import rx.perf.AbstractPerformanceTester;
+import rx.perf.IntegerSumObserver;
+import rx.schedulers.Schedulers;
+import rx.util.functions.Action0;
+
+public class OperatorObserveOnPerformance extends AbstractPerformanceTester {
+
+    private static long reps = 1000000;
+
+    OperatorObserveOnPerformance() {
+        super(reps);
+    }
+
+    public static void main(String args[]) {
+
+        final OperatorObserveOnPerformance spt = new OperatorObserveOnPerformance();
+        try {
+            spt.runTest(new Action0() {
+
+                @Override
+                public void call() {
+                    spt.timeObserveOn();
+                }
+            });
+        } catch (Exception e) {
+            e.printStackTrace();
+        }
+
+    }
+
+    /**
+     * Observable.from(1L).observeOn()
+     * 
+     */
+    public long timeObserveOn() {
+
+        Observable<Integer> s = Observable.range(1, (int) reps).observeOn(Schedulers.newThread());
+        IntegerSumObserver o = new IntegerSumObserver();
+        s.subscribe(o);
+        return o.sum;
+    }
+
+}

rxjava-core/src/perf/java/rx/operators/OperatorTakePerformance.java

@@ -7,6 +7,10 @@
 
 public class OperatorTakePerformance extends AbstractPerformanceTester {
 
+    OperatorTakePerformance() {
+        super(REPETITIONS);
+    }
+    
     public static void main(String args[]) {
 
         final OperatorTakePerformance spt = new OperatorTakePerformance();

rxjava-core/src/perf/java/rx/operators/OperatorZipPerformance.java

@@ -3,12 +3,15 @@
 import rx.Observable;
 import rx.perf.AbstractPerformanceTester;
 import rx.perf.IntegerSumObserver;
-import rx.perf.LongSumObserver;
 import rx.util.functions.Action0;
 import rx.util.functions.Func2;
 
 public class OperatorZipPerformance extends AbstractPerformanceTester {
 
+    OperatorZipPerformance() {
+        super(REPETITIONS);
+    }
+    
     public static void main(String args[]) {
 
         final OperatorZipPerformance spt = new OperatorZipPerformance();

rxjava-core/src/perf/java/rx/perf/AbstractPerformanceTester.java

@@ -6,9 +6,15 @@
 
 public abstract class AbstractPerformanceTester {
 
-    public static final int REPETITIONS = 5 * 1000 * 1000;
+    public static final long REPETITIONS = 5 * 1000 * 1000;
     public static final int NUM_PRODUCERS = 1;
 
+    private final long repetitions;
+
+    protected AbstractPerformanceTester(long repetitions) {
+        this.repetitions = repetitions;
+    }
+
     public final void runTest(Action0 action) throws InterruptedException {
         for (int runNum = 0; runNum < 15; runNum++) {
             System.gc();
@@ -19,7 +25,7 @@ public final void runTest(Action0 action) throws InterruptedException {
             action.call();
 
             long duration = System.nanoTime() - start;
-            long opsPerSec = (REPETITIONS * NUM_PRODUCERS * 1000L * 1000L * 1000L) / duration;
+            long opsPerSec = (repetitions * NUM_PRODUCERS * 1000L * 1000L * 1000L) / duration;
             System.out.printf("Run: %d - %,d ops/sec \n",
                     Integer.valueOf(runNum),
                     Long.valueOf(opsPerSec));
@@ -39,14 +45,14 @@ public final void runTest(Action0 action) throws InterruptedException {
      */
     public long baseline() {
         LongSumObserver o = new LongSumObserver();
-        for (long l = 0; l < REPETITIONS; l++) {
+        for (long l = 0; l < repetitions; l++) {
             o.onNext(l);
         }
         o.onCompleted();
         return o.sum;
     }
-    
-    public static Iterable<Long> ITERABLE_OF_REPETITIONS = new Iterable<Long>() {
+
+    public Iterable<Long> ITERABLE_OF_REPETITIONS = new Iterable<Long>() {
 
         @Override
         public Iterator<Long> iterator() {
@@ -55,7 +61,7 @@ public Iterator<Long> iterator() {
 
                 @Override
                 public boolean hasNext() {
-                    return count <= REPETITIONS;
+                    return count <= repetitions;
                 }
 
                 @Override
@@ -71,5 +77,5 @@ public void remove() {
             };
         };
     };
-    
+
 }

rxjava-core/src/perf/java/rx/subscriptions/CompositeSubscriptionAddRemovePerf.java

@@ -4,6 +4,11 @@
 import rx.util.functions.Action0;
 
 public class CompositeSubscriptionAddRemovePerf extends AbstractPerformanceTester {
+
+    CompositeSubscriptionAddRemovePerf() {
+        super(REPETITIONS);
+    }
+
     public static void main(String[] args) {
         final CompositeSubscriptionAddRemovePerf spt = new CompositeSubscriptionAddRemovePerf();
         try {