blob: c6afdced255d6480ed87c7f712b47615314e63c2 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
|
/*
* Copyright 2016-2018 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license.
*/
package benchmarks.actors
import kotlinx.coroutines.*
import kotlinx.coroutines.channels.*
import kotlinx.coroutines.scheduling.*
import org.openjdk.jmh.annotations.*
import java.util.concurrent.*
import kotlin.coroutines.*
/*
* Benchmark Mode Cnt Score Error Units
* PingPongWithBlockingContext.commonPoolWithContextPingPong avgt 20 972.662 ± 103.448 ms/op
* PingPongWithBlockingContext.limitingDispatcherPingPong avgt 20 136.167 ± 4.971 ms/op
* PingPongWithBlockingContext.withContextPingPong avgt 20 761.669 ± 41.371 ms/op
*/
@Warmup(iterations = 5, time = 1, timeUnit = TimeUnit.SECONDS)
@Measurement(iterations = 10, time = 1, timeUnit = TimeUnit.SECONDS)
@Fork(value = 2)
@BenchmarkMode(Mode.AverageTime)
@OutputTimeUnit(TimeUnit.MILLISECONDS)
@State(Scope.Benchmark)
open class PingPongWithBlockingContext {
@UseExperimental(InternalCoroutinesApi::class)
private val experimental = ExperimentalCoroutineDispatcher(8)
@UseExperimental(InternalCoroutinesApi::class)
private val blocking = experimental.blocking(8)
private val threadPool = newFixedThreadPoolContext(8, "PongCtx")
@TearDown
fun tearDown() {
threadPool.close()
}
@Benchmark
fun limitingDispatcherPingPong() = runBlocking {
runPingPongs(experimental, blocking)
}
@Benchmark
fun withContextPingPong() = runBlocking {
runPingPongs(experimental, threadPool)
}
@Benchmark
fun commonPoolWithContextPingPong() = runBlocking {
runPingPongs(ForkJoinPool.commonPool().asCoroutineDispatcher(), threadPool)
}
private suspend fun runPingPongs(pingContext: CoroutineContext, pongContext: CoroutineContext) {
val me = Channel<PingPongActorBenchmark.Letter>()
val pong = CoroutineScope(pongContext).pongActorCoroutine()
val ping = CoroutineScope(pingContext).pingActorCoroutine(pong)
ping.send(PingPongActorBenchmark.Letter(Start(), me))
me.receive()
}
}
|
