Rename JMH tests for easier execution by regex

hystrix-core/src/jmh/java/com/netflix/hystrix/perf/MultiThreadedMetricsTest.java → hystrix-core/src/jmh/java/com/netflix/hystrix/perf/CommandExecutionAndConcurrentMetricsReadPerfTest.java

@@ -34,7 +34,7 @@
 
 import java.util.concurrent.TimeUnit;
 
-public class MultiThreadedMetricsTest {
+public class CommandExecutionAndConcurrentMetricsReadPerfTest {
     @State(Scope.Thread)
     public static class CommandState {
         HystrixCommand<Integer> command;

hystrix-core/src/jmh/java/com/netflix/hystrix/perf/CommandSetterExecutionPerfTest.java → hystrix-core/src/jmh/java/com/netflix/hystrix/perf/CommandExecutionPerfTest.java

@@ -31,6 +31,7 @@
 import org.openjdk.jmh.annotations.Setup;
 import org.openjdk.jmh.annotations.State;
 import org.openjdk.jmh.annotations.TearDown;
+import org.openjdk.jmh.infra.Blackhole;
 import rx.Observable;
 import rx.schedulers.Schedulers;
 
@@ -41,38 +42,52 @@
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
 
-public class CommandSetterExecutionPerfTest {
+public class CommandExecutionPerfTest {
+
+    static HystrixCommandProperties.Setter threadIsolatedCommandDefaults = HystrixCommandProperties.Setter()
+            .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.THREAD)
+            .withRequestCacheEnabled(true)
+            .withRequestLogEnabled(true)
+            .withCircuitBreakerEnabled(true)
+            .withCircuitBreakerForceOpen(false);
+
+    static HystrixCommandProperties.Setter semaphoreIsolatedCommandDefaults = HystrixCommandProperties.Setter()
+            .withExecutionIsolationStrategy(HystrixCommandProperties.ExecutionIsolationStrategy.SEMAPHORE)
+            .withRequestCacheEnabled(true)
+            .withRequestLogEnabled(true)
+            .withCircuitBreakerEnabled(true)
+            .withCircuitBreakerForceOpen(false);
+
+    static HystrixThreadPoolProperties.Setter threadPoolDefaults = HystrixThreadPoolProperties.Setter()
+            .withCoreSize(100);
+
+    private static HystrixCommandProperties.Setter getCommandSetter(HystrixCommandProperties.ExecutionIsolationStrategy isolationStrategy) {
+        switch (isolationStrategy) {
+            case THREAD: return threadIsolatedCommandDefaults;
+            default: return semaphoreIsolatedCommandDefaults;
+        }
+    }
 
     @State(Scope.Thread)
     public static class CommandState {
         HystrixCommand<Integer> command;
 
-        @Param({"true", "false"})
-        public boolean forceCircuitOpen;
-
         @Param({"THREAD", "SEMAPHORE"})
         public HystrixCommandProperties.ExecutionIsolationStrategy isolationStrategy;
 
+        @Param({"1", "100", "10000"})
+        public int blackholeConsumption;
 
         @Setup(Level.Invocation)
         public void setUp() {
             command = new HystrixCommand<Integer>(
                     HystrixCommand.Setter.withGroupKey(HystrixCommandGroupKey.Factory.asKey("PERF"))
-                            .andCommandPropertiesDefaults(
-                                    HystrixCommandProperties.Setter()
-                                            .withExecutionIsolationStrategy(isolationStrategy)
-                                            .withRequestCacheEnabled(true)
-                                            .withRequestLogEnabled(true)
-                                            .withCircuitBreakerEnabled(true)
-                                            .withCircuitBreakerForceOpen(forceCircuitOpen)
-                            )
-                            .andThreadPoolPropertiesDefaults(
-                                    HystrixThreadPoolProperties.Setter()
-                                            .withCoreSize(100)
-                            )
+                            .andCommandPropertiesDefaults(getCommandSetter(isolationStrategy))
+                            .andThreadPoolPropertiesDefaults(threadPoolDefaults)
             ) {
                 @Override
                 protected Integer run() throws Exception {
+                    Blackhole.consumeCPU(blackholeConsumption);
                     return 1;
                 }