Glad to hear that.
/Patrik
On Tue, Nov 25, 2014 at 8:52 PM, Hector123 <[email protected]> wrote:
> I got this resolved , it was an error with the configuration json object.
> here is the correct setting
>
> akka {
> actor{
> default-dispatcher {
> type = Dispatcher
> executor = "thread-pool-executor"
> throughput = 1000
> fork-join-executor {
> parallelism-min = 32
> parallelism-factor = 0.5
> parallelism-max = 64
>
> }
>
>
> On Tuesday, November 25, 2014 8:04:27 AM UTC-8, Hector123 wrote:
>>
>> 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.
>
--
Patrik Nordwall
Typesafe <http://typesafe.com/> - Reactive apps on the JVM
Twitter: @patriknw
--
>>>>>>>>>> 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.
