Update channel "producer-consumer" and semaphore micro-benchmarks

Author: ndkoval

benchmarks/src/jmh/kotlin/benchmarks/ChannelProducerConsumerBenchmark.kt

@@ -6,6 +6,7 @@ package benchmarks
 
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.Channel
+import kotlinx.coroutines.scheduling.*
 import kotlinx.coroutines.selects.select
 import org.openjdk.jmh.annotations.*
 import org.openjdk.jmh.infra.Blackhole
@@ -33,7 +34,7 @@ import java.util.concurrent.TimeUnit
 @State(Scope.Benchmark)
 open class ChannelProducerConsumerBenchmark {
     @Param
-    private var _0_dispatcher: DispatcherCreator = DispatcherCreator.FORK_JOIN
+    private var _0_dispatcher: DispatcherCreator = DispatcherCreator.DEFAULT
 
     @Param
     private var _1_channel: ChannelCreator = ChannelCreator.RENDEZVOUS
@@ -44,10 +45,8 @@ open class ChannelProducerConsumerBenchmark {
     @Param("false", "true")
     private var _3_withSelect: Boolean = false
 
-    @Param("1", "2", "4") // local machine
-//    @Param("1", "2", "4", "8", "12") // local machine
-//    @Param("1", "2", "4", "8", "16", "32", "64", "128", "144") // dasquad
-//    @Param("1", "2", "4", "8", "16", "32", "64", "96") // Google Cloud
+    @Param("1", "2", "4", "8", "16") // local machine
+//    @Param("1", "2", "4", "8", "16", "32", "64", "128") // Server
     private var _4_parallelism: Int = 0
 
     private lateinit var dispatcher: CoroutineDispatcher
@@ -128,14 +127,14 @@ open class ChannelProducerConsumerBenchmark {
 }
 
 enum class DispatcherCreator(val create: (parallelism: Int) -> CoroutineDispatcher) {
-    FORK_JOIN({ parallelism ->  ForkJoinPool(parallelism).asCoroutineDispatcher() })
+    //FORK_JOIN({ parallelism ->  ForkJoinPool(parallelism).asCoroutineDispatcher() }),
+    @Suppress("INVISIBLE_MEMBER", "INVISIBLE_REFERENCE")
+    DEFAULT({ parallelism -> ExperimentalCoroutineDispatcher(corePoolSize = parallelism, maxPoolSize = parallelism) })
 }
 
 enum class ChannelCreator(private val capacity: Int) {
     RENDEZVOUS(Channel.RENDEZVOUS),
-//    BUFFERED_1(1),
-    BUFFERED_2(2),
-//    BUFFERED_4(4),
+    BUFFERED_4(4),
     BUFFERED_32(32),
     BUFFERED_128(128),
     BUFFERED_UNLIMITED(Channel.UNLIMITED);

benchmarks/src/jmh/kotlin/benchmarks/SemaphoreBenchmark.kt

@@ -7,6 +7,7 @@ package benchmarks
 import benchmarks.common.*
 import kotlinx.coroutines.*
 import kotlinx.coroutines.channels.*
+import kotlinx.coroutines.scheduling.*
 import kotlinx.coroutines.sync.*
 import org.openjdk.jmh.annotations.*
 import java.util.concurrent.*
@@ -19,17 +20,16 @@ import java.util.concurrent.*
 @State(Scope.Benchmark)
 open class SemaphoreBenchmark {
     @Param
-    private var _1_dispatcher: SemaphoreBenchDispatcherCreator = SemaphoreBenchDispatcherCreator.FORK_JOIN
+    private var _1_dispatcher: SemaphoreBenchDispatcherCreator = SemaphoreBenchDispatcherCreator.DEFAULT
 
     @Param("0", "1000")
     private var _2_coroutines: Int = 0
 
     @Param("1", "2", "4", "8", "32", "128", "100000")
     private var _3_maxPermits: Int = 0
 
-    @Param("1", "2", "4") // local machine
-//    @Param("1", "2", "4", "8", "16", "32", "64", "128", "144") // dasquad
-//    @Param("1", "2", "4", "8", "16", "32", "64", "96") // Google Cloud
+    @Param("1", "2", "4", "8", "16") // local machine
+//    @Param("1", "2", "4", "8", "16", "32", "64", "128") // Server
     private var _4_parallelism: Int = 0
 
     private lateinit var dispatcher: CoroutineDispatcher
@@ -80,10 +80,11 @@ open class SemaphoreBenchmark {
 }
 
 enum class SemaphoreBenchDispatcherCreator(val create: (parallelism: Int) -> CoroutineDispatcher) {
-    FORK_JOIN({ parallelism -> ForkJoinPool(parallelism).asCoroutineDispatcher() }),
-    EXPERIMENTAL({ parallelism -> Dispatchers.Default }) // TODO doesn't take parallelism into account
+    //    FORK_JOIN({ parallelism -> ForkJoinPool(parallelism).asCoroutineDispatcher() }),
+    @Suppress("INVISIBLE_MEMBER", "INVISIBLE_REFERENCE")
+    DEFAULT({ parallelism -> ExperimentalCoroutineDispatcher(corePoolSize = parallelism, maxPoolSize = parallelism) })
 }
 
-private const val WORK_INSIDE = 80
-private const val WORK_OUTSIDE = 40
-private const val BATCH_SIZE = 1000000
+private const val WORK_INSIDE = 50
+private const val WORK_OUTSIDE = 50
+private const val BATCH_SIZE = 100000