Hello,
I created an application that uses Akka with RoundRobin routers. The
application takes a list of files to processes them in parallel. My issue
is that regardless of the number of workers that I specify the application
processes only 12 files at a time. Is there a certain setting that I need
to change ?
my code :
val conf1 = ConfigFactory.load(ConfigFactory.parseString("""
akka
default-dispatcher {
type = Dispatcher
executor = "fork-join-executor"
throughput = 1000
fork-join-executor {
parallelism-min = 32
parallelism-factor = 0.5
parallelism-max = 64
}
}
}"""))
val system = ActorSystem("MySystem", conf1)
val master = system.actorOf(Props[MasterClassName],name="myactor")
master ! CaseClass1
and then in the master class , here is how I initialize the workers:
val nworkers=20 // or 30
val workers = context
.actorOf(Props[ClassWorker].withRouter(RoundRobinRouter(nworkers)))
Any idea why ?
--
>>>>>>>>>> Read the docs: http://akka.io/docs/
>>>>>>>>>> Check the FAQ:
>>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html
>>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user
---
You received this message because you are subscribed to the Google Groups "Akka
User List" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to [email protected].
To post to this group, send email to [email protected].
Visit this group at http://groups.google.com/group/akka-user.
For more options, visit https://groups.google.com/d/optout.
