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

Remove router benchmark, see #944

Browse source
This commit is contained in:
Patrik Nordwall 2012-09-17 12:12:19 +02:00
parent 48a0fda991
commit b4f5948340
1 changed files with 0 additions and 79 deletions
Download patch file Download diff file Expand all files Collapse all files

79
akka-actor-tests/src/test/scala/perf/RouterPerf.scala
View file

@ -1,79 +0,0 @@
package perf
import akka.actor.ActorSystem
import akka.actor.Actor
import akka.actor.Props
import scala.concurrent.forkjoin.ThreadLocalRandom
import akka.routing.ConsistentHashingRouter
import akka.routing.ConsistentHashingRouter.ConsistentHashableEnvelope
import scala.util.Random
import akka.routing.Broadcast
import akka.actor.ActorLogging
import scala.concurrent.util.Duration
import akka.routing.RoundRobinRouter
object RouterPerf extends App {
val system = ActorSystem("PerfApp")
var perf = new RouterPerf(system)
// Thread.sleep(20000) // hook up profiler here
perf.run()
}
class RouterPerf(system: ActorSystem) {
def run(): Unit = {
// nbrMessages = 10000000
val sender = system.actorOf(Props(new Sender(
nbrMessages = 10000000, nbrRoutees = 10, nbrIterations = 10)), name = "sender")
sender ! "start"
}
}
class Sender(nbrMessages: Int, nbrRoutees: Int, nbrIterations: Int) extends Actor with ActorLogging {
val router = context.actorOf(Props[Destination].withRouter(ConsistentHashingRouter(nbrRoutees,
virtualNodesFactor = 10)), "router")
// val router = context.actorOf(Props[Destination].withRouter(RoundRobinRouter(nbrRoutees)), "router")
val rnd = new Random
val messages = Vector.fill(1000)(ConsistentHashableEnvelope("msg", rnd.nextString(10)))
var startTime = 0L
var doneCounter = 0
var iterationCounter = 0
def receive = {
case "start" ⇒
iterationCounter += 1
doneCounter = 0
startTime = System.nanoTime
val messgesSize = messages.size
for (n ← 1 to nbrMessages) { router ! messages(n % messgesSize) }
router ! Broadcast("done")
case "done" ⇒
doneCounter += 1
if (doneCounter == nbrRoutees) {
val duration = Duration.fromNanos(System.nanoTime - startTime)
val mps = (nbrMessages.toDouble * 1000 / duration.toMillis).toInt
// log.info("Processed [{}] messages in [{} millis], i.e. [{}] msg/s",
// nbrMessages, duration.toMillis, mps)
println("Processed [%s] messages in [%s millis], i.e. [%s] msg/s".format(
nbrMessages, duration.toMillis, mps))
if (iterationCounter < nbrIterations)
self ! "start"
else
context.system.shutdown()
}
}
}
class Destination extends Actor with ActorLogging {
var count = 0
def receive = {
case "done" ⇒
log.info("Handled [{}] messages", count)
count = 0
sender ! "done"
case msg ⇒ count += 1
}
}