diff --git a/src/main/java/edu/lu/uni/serval/MultipleThreadsParser/AkkaParser.java b/src/main/java/edu/lu/uni/serval/MultipleThreadsParser/AkkaParser.java index cebec75..d6682d3 100644 --- a/src/main/java/edu/lu/uni/serval/MultipleThreadsParser/AkkaParser.java +++ b/src/main/java/edu/lu/uni/serval/MultipleThreadsParser/AkkaParser.java @@ -34,7 +34,7 @@ public class AkkaParser { ActorSystem system = null; ActorRef parsingActor = null; - final int numberOfWorkers = 200; + final int numberOfWorkers = 30; final WorkMessage msg = new WorkMessage(0, msgFiles); try { log.info("Akka begins...");