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 }