1 package xuml.tools.model.compiler.runtime; 2 3 import java.util.concurrent.ExecutorService; 4 import java.util.concurrent.Executors; 5 import java.util.concurrent.ThreadFactory; 6 7 import com.typesafe.config.Config; 8 9 import akka.dispatch.DispatcherPrerequisites; 10 import akka.dispatch.ExecutorServiceConfigurator; 11 import akka.dispatch.ExecutorServiceFactory; 12 13 public class EntityExecutorServiceConfigurator extends ExecutorServiceConfigurator { 14 15 public EntityExecutorServiceConfigurator(Config config, DispatcherPrerequisites prerequisites) { 16 super(config, prerequisites); 17 } 18 19 @Override 20 public ExecutorServiceFactory createExecutorServiceFactory(String id, ThreadFactory factory) { 21 return new ExecutorServiceFactory() { 22 23 @Override 24 public ExecutorService createExecutorService() { 25 return Executors.newFixedThreadPool(5); 26 } 27 }; 28 } 29 30 }