###Implementation of Concurrency and Fault Tolerance Made Easy: An Akka Tutorial with Examples
Using Akka Actors this reads all text files in a directory and counts the number of words in each file.
This is an Intellij SBT project, so you can clone it and play around. I hope this helps someone! 😀
Example output:
Stream Complete: 2.txt Total Number of Words: 13084 Total Time: 148ms
Stream Complete: 4.txt Total Number of Words: 13084 Total Time: 113ms
Stream Complete: 8.txt Total Number of Words: 9100 Total Time: 107ms
Stream Complete: 5.txt Total Number of Words: 13084 Total Time: 160ms
Stream Complete: 6.txt Total Number of Words: 9100 Total Time: 99ms
Stream Complete: 7.txt Total Number of Words: 9100 Total Time: 109ms
Stream Complete: 3.txt Total Number of Words: 13084 Total Time: 238ms
Stream Complete: 10.txt Total Number of Words: 26168 Total Time: 306ms
Stream Complete: 9.txt Total Number of Words: 1256064 Total Time: 1267ms
Stream Complete: 1.txt Total Number of Words: 1256064 Total Time: 1283ms
####Update: Don't create a new ActorSystem for each file.
Thanks Reddit User mmccaskill for pointing it out.
-
The solution was to pass in the ActorSystem as a parameter.
-
Don't name the Listener and Router Actors let Akka do it, so it will be unique
-
Keep count of the number of files processed, so you can terminate the ActorSystem when everything finishes.
Read more here: [Do I need to re-use the same Akka ActorSystem or can I just create one every time I need one?] (https://stackoverflow.com/questions/10396552/do-i-need-to-re-use-the-same-akka-actorsystem-or-can-i-just-create-one-every-tim)
####Messages are sent to an Actor through one of the following methods.
!means “fire-and-forget”, e.g. send a message asynchronously and return immediately. Also known as tell.?sends a message asynchronously and returns a Future representing a possible reply. Also known as ask