Add the number of workers.

This commit is contained in:
Kui LIU
2017-08-16 10:56:35 +02:00
parent 7fd886c815
commit 11bd352ec8
@@ -44,7 +44,7 @@ public class AkkaParser {
ActorSystem system = null; ActorSystem system = null;
ActorRef parsingActor = null; ActorRef parsingActor = null;
int numberOfWorkers = 30; int numberOfWorkers = 100;
final WorkMessage msg = new WorkMessage(0, msgFiles); final WorkMessage msg = new WorkMessage(0, msgFiles);
try { try {
log.info("Akka begins..."); log.info("Akka begins...");