Fix jmh

Author: Artemyev Vyacheslav

.gitignore

@@ -12,3 +12,6 @@ CONTENT.md
 
 #JMH
 benchmarks.jar
+
+# MacOS
+.DS_Store

benchmarks/src/jmh/kotlin/com.viartemev.thewhiterabbit/ConfirmPublisherBenchmark.kt

@@ -7,21 +7,11 @@ import com.viartemev.thewhiterabbit.channel.ConfirmChannel
 import com.viartemev.thewhiterabbit.channel.createConfirmChannel
 import com.viartemev.thewhiterabbit.publisher.ConfirmPublisher
 import com.viartemev.thewhiterabbit.publisher.OutboundMessage
+import kotlinx.coroutines.Dispatchers
+import kotlinx.coroutines.async
 import kotlinx.coroutines.awaitAll
 import kotlinx.coroutines.runBlocking
-import org.openjdk.jmh.annotations.Benchmark
-import org.openjdk.jmh.annotations.BenchmarkMode
-import org.openjdk.jmh.annotations.Fork
-import org.openjdk.jmh.annotations.Level
-import org.openjdk.jmh.annotations.Measurement
-import org.openjdk.jmh.annotations.Mode
-import org.openjdk.jmh.annotations.OutputTimeUnit
-import org.openjdk.jmh.annotations.Param
-import org.openjdk.jmh.annotations.Scope
-import org.openjdk.jmh.annotations.Setup
-import org.openjdk.jmh.annotations.State
-import org.openjdk.jmh.annotations.TearDown
-import org.openjdk.jmh.annotations.Warmup
+import org.openjdk.jmh.annotations.*
 import org.openjdk.jmh.infra.Blackhole
 import java.util.concurrent.TimeUnit
 
@@ -46,7 +36,7 @@ open class ConfirmPublisherBenchmark {
         channel = connection.createConfirmChannel()
         channel.queueDeclare(testQueueName, false, false, false, mapOf())
         publisher = channel.publisher()
-        messages = (1..numberOfMessages).map { createMessage() }
+        messages = (1..numberOfMessages).map { OutboundMessage("", testQueueName, MessageProperties.MINIMAL_BASIC, "") }
     }
 
     @TearDown(Level.Iteration)
@@ -60,16 +50,13 @@ open class ConfirmPublisherBenchmark {
     @BenchmarkMode(Mode.AverageTime)
     @OutputTimeUnit(TimeUnit.MICROSECONDS)
     fun avgTimeSendWithPublishConfirm(blackhole: Blackhole) = runBlocking {
-        blackhole.consume(publisher.publishWithConfirmAsync(messages = messages).awaitAll())
+        blackhole.consume(messages.map { async(Dispatchers.IO) { publisher.publishWithConfirm(it) } }.awaitAll())
     }
 
     @Benchmark
     @BenchmarkMode(Mode.Throughput)
     @OutputTimeUnit(TimeUnit.MICROSECONDS)
     fun throughputSendWithPublishConfirm(blackhole: Blackhole) = runBlocking {
-        blackhole.consume(publisher.publishWithConfirmAsync(messages = messages).awaitAll())
+        blackhole.consume(messages.map { async(Dispatchers.IO) { publisher.publishWithConfirm(it) } }.awaitAll())
     }
-
-
-    private fun createMessage(): OutboundMessage = OutboundMessage("", testQueueName, MessageProperties.MINIMAL_BASIC, "")
 }

build.gradle

@@ -24,6 +24,8 @@ buildscript {
 plugins {
     id("jacoco")
     id "com.github.johnrengelman.shadow" version "8.1.1"
+    id "org.jetbrains.dokka" version "1.9.10"
+    id "java-library"
 }
 
 configure(allprojects) { project ->