View Javadoc
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  }