summaryrefslogtreecommitdiff
path: root/src/main/java/com/p4square/grow/frontend/GrowFrontend.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/p4square/grow/frontend/GrowFrontend.java')
-rw-r--r--src/main/java/com/p4square/grow/frontend/GrowFrontend.java9
1 files changed, 9 insertions, 0 deletions
diff --git a/src/main/java/com/p4square/grow/frontend/GrowFrontend.java b/src/main/java/com/p4square/grow/frontend/GrowFrontend.java
index b5f62fb..ebaa8df 100644
--- a/src/main/java/com/p4square/grow/frontend/GrowFrontend.java
+++ b/src/main/java/com/p4square/grow/frontend/GrowFrontend.java
@@ -7,6 +7,8 @@ package com.p4square.grow.frontend;
import java.io.File;
import java.io.IOException;
import java.lang.reflect.Constructor;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
import freemarker.template.Template;
@@ -51,6 +53,8 @@ public class GrowFrontend extends FMFacade {
private IntegrationDriver mIntegrationFactory;
+ private final ExecutorService mThreadPool;
+
public GrowFrontend() {
this(new Config(), new MetricRegistry());
}
@@ -58,6 +62,7 @@ public class GrowFrontend extends FMFacade {
public GrowFrontend(Config config, MetricRegistry metricRegistry) {
mConfig = config;
mMetricRegistry = metricRegistry;
+ mThreadPool = Executors.newFixedThreadPool(mConfig.getInt("threadPoolSize", 10));
}
public Config getConfig() {
@@ -68,6 +73,10 @@ public class GrowFrontend extends FMFacade {
return mMetricRegistry;
}
+ public ExecutorService getThreadPool() {
+ return mThreadPool;
+ }
+
@Override
public synchronized void start() throws Exception {
Template errorTemplate = getTemplate("templates/error.ftl");