Decrease the number of workers.

This commit is contained in:
Kui LIU
2017-08-02 13:42:47 +02:00
parent 1c7d58c17c
commit cbddfdec34
@@ -34,7 +34,7 @@ public class AkkaParser {
ActorSystem system = null; ActorSystem system = null;
ActorRef parsingActor = null; ActorRef parsingActor = null;
final int numberOfWorkers = 200; final int numberOfWorkers = 30;
final WorkMessage msg = new WorkMessage(0, msgFiles); final WorkMessage msg = new WorkMessage(0, msgFiles);
try { try {
log.info("Akka begins..."); log.info("Akka begins...");