raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Fixed warnings in akka-bench-jmh-typed (#27435)

Browse source
This commit is contained in:
Helena Edelson 2019-08-02 14:02:51 -07:00 • committed by GitHub
parent d12bc13fcb
commit 473d4f71d7
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
3 changed files with 8 additions and 14 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-bench-jmh-typed/src/main/scala/akka/actor/typed/TypedActorBenchmark.scala
View file

@ -54,7 +54,7 @@ class TypedActorBenchmark {
def setup(): Unit = { def setup(): Unit = {
akka.actor.BenchmarkActors.requireRightNumberOfCores(threads) akka.actor.BenchmarkActors.requireRightNumberOfCores(threads)
system = ActorSystem( system = ActorSystem(
TypedBenchmarkActors.echoActorsSupervisor(numMessagesPerActorPair, numActors, dispatcher, batchSize, timeout), TypedBenchmarkActors.echoActorsSupervisor(numMessagesPerActorPair, numActors, dispatcher, batchSize),
"TypedActorBenchmark", "TypedActorBenchmark",
ConfigFactory.parseString(s""" ConfigFactory.parseString(s"""
akka.actor { akka.actor {

13
akka-bench-jmh-typed/src/main/scala/akka/actor/typed/TypedBenchmarkActors.scala
View file

@ -6,12 +6,12 @@ package akka.actor.typed
import java.util.concurrent.CountDownLatch import java.util.concurrent.CountDownLatch
import scala.concurrent.duration._
import akka.Done import akka.Done
import akka.actor.typed.scaladsl.ActorContext import akka.actor.typed.scaladsl.ActorContext
import akka.actor.typed.scaladsl.Behaviors import akka.actor.typed.scaladsl.Behaviors
import scala.concurrent.duration._
object TypedBenchmarkActors { object TypedBenchmarkActors {
// to avoid benchmark to be dominated by allocations of message // to avoid benchmark to be dominated by allocations of message
@ -65,8 +65,7 @@ object TypedBenchmarkActors {
numMessagesPerActorPair: Int, numMessagesPerActorPair: Int,
numActors: Int, numActors: Int,
dispatcher: String, dispatcher: String,
batchSize: Int, batchSize: Int): Behavior[Start] =
shutdownTimeout: FiniteDuration): Behavior[Start] =
Behaviors.receive { (ctx, msg) => Behaviors.receive { (ctx, msg) =>
msg match { msg match {
case Start(respondTo) => case Start(respondTo) =>
@ -146,11 +145,9 @@ object TypedBenchmarkActors {
private def initiatePingPongForPairs(refs: Vector[(ActorRef[Message], ActorRef[Message])], inFlight: Int): Unit = { private def initiatePingPongForPairs(refs: Vector[(ActorRef[Message], ActorRef[Message])], inFlight: Int): Unit = {
for { for {
(ping, pong) <- refs (ping, pong) <- refs
val message = Message(pong) // just allocate once message = Message(pong) // just allocate once
_ <- 1 to inFlight _ <- 1 to inFlight
} { } ping ! message
ping ! message
}
} }
private def startPingPongActorPairs( private def startPingPongActorPairs(

7
project/AkkaDisciplinePlugin.scala
View file

@ -17,11 +17,8 @@ object AkkaDisciplinePlugin extends AutoPlugin with ScalafixSupport {
override def requires: Plugins = JvmPlugin && ScalafixPlugin override def requires: Plugins = JvmPlugin && ScalafixPlugin
override lazy val projectSettings = disciplineSettings override lazy val projectSettings = disciplineSettings
val nonFatalWarningsFor = Set( // We allow warnings in docs to get the 'snippets' right
// We allow warnings in docs to get the 'snippets' right val nonFatalWarningsFor = Set("akka-docs")
"akka-docs",
// To be reviewed
"akka-bench-jmh-typed")
val strictProjects = Set("akka-discovery", "akka-protobuf", "akka-coordination") val strictProjects = Set("akka-discovery", "akka-protobuf", "akka-coordination")