Merge pull request #1290 from benjchristensen/jmh-upgrade

Upgrade to JMH 0.7.3

Author: benjchristensen

build.gradle

@@ -61,9 +61,8 @@ subprojects {
     }
 
     dependencies {
-        perfCompile 'org.openjdk.jmh:jmh-core:0.5.3'
-        perfCompile 'org.openjdk.jmh:jmh-generator-annprocess:0.5.3'
-        //perfCompile project
+        perfCompile 'org.openjdk.jmh:jmh-core:0.7.3'
+        perfCompile 'org.openjdk.jmh:jmh-generator-annprocess:0.7.3'
     }
 
     artifacts {

rxjava-core/src/perf/java/rx/archive/operators/OperatorSerializePerformance.java

@@ -3,6 +3,7 @@
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
+import org.openjdk.jmh.annotations.Setup;
 import org.openjdk.jmh.logic.BlackHole;
 
 import rx.Observable;
@@ -27,30 +28,6 @@ public class OperatorSerializePerformance extends AbstractPerformanceTester {
         super(reps);
     }
 
-    public static void main(String args[]) {
-
-        final OperatorSerializePerformance spt = new OperatorSerializePerformance();
-        final Input input = new Input();
-        input.setup();
-        try {
-            spt.runTest(new Action0() {
-
-                @Override
-                public void call() {
-                    //                    spt.noSerializationSingleThreaded(input);
-                    spt.serializedSingleStream(input);
-                    //                    spt.synchronizedSingleStream(input);
-                    //                    spt.timeTwoStreams();
-                    //                    spt.timeSingleStream();
-                    //                    spt.timeTwoStreamsIntervals();
-                }
-            });
-        } catch (Exception e) {
-            e.printStackTrace();
-        }
-
-    }
-
     /**
      * Run: 10 - 12,186,982 ops/sec
      * Run: 11 - 10,236,722 ops/sec
@@ -379,7 +356,8 @@ public static class Input {
 
         private CountDownLatch latch;
 
-        public void setup() {
+        @Setup
+        public void setup(final BlackHole bh) {
             observable = Observable.create(new OnSubscribe<Integer>() {
                 @Override
                 public void call(Subscriber<? super Integer> o) {
@@ -392,7 +370,6 @@ public void call(Subscriber<? super Integer> o) {
                 }
             });
 
-            final BlackHole bh = new BlackHole();
             latch = new CountDownLatch(1);
 
             subscriber = new TestSubscriber<Integer>(new Observer<Integer>() {

rxjava-core/src/perf/java/rx/jmh/InputWithIncrementingInteger.java

@@ -42,7 +42,7 @@ public class InputWithIncrementingInteger {
     private CountDownLatch latch;
 
     @Setup
-    public void setup() {
+    public void setup(final BlackHole bh) {
         observable = Observable.create(new OnSubscribe<Integer>() {
             @Override
             public void call(Subscriber<? super Integer> o) {
@@ -55,7 +55,6 @@ public void call(Subscriber<? super Integer> o) {
             }
         });
 
-        final BlackHole bh = new BlackHole();
         latch = new CountDownLatch(1);
 
         observer = new Observer<Integer>() {

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

@@ -54,7 +54,7 @@ public static class Input {
         private CountDownLatch latch;
 
         @Setup
-        public void setup() {
+        public void setup(final BlackHole bh) {
             observable = Observable.create(new OnSubscribe<Integer>() {
                 @Override
                 public void call(Subscriber<? super Integer> o) {
@@ -67,7 +67,6 @@ public void call(Subscriber<? super Integer> o) {
                 }
             });
 
-            final BlackHole bh = new BlackHole();
             latch = new CountDownLatch(1);
 
             subscriber = new TestSubscriber<Integer>(new Observer<Integer>() {

rxjava-core/src/perf/java/rx/usecases/UseCaseInput.java

@@ -42,7 +42,7 @@ public class UseCaseInput {
     private CountDownLatch latch;
 
     @Setup
-    public void setup() {
+    public void setup(final BlackHole bh) {
         observable = Observable.create(new OnSubscribe<Integer>() {
             @Override
             public void call(Subscriber<? super Integer> o) {
@@ -53,7 +53,6 @@ public void call(Subscriber<? super Integer> o) {
             }
         });
 
-        final BlackHole bh = new BlackHole();
         latch = new CountDownLatch(1);
 
         observer = new Observer<Integer>() {