X-Git-Url: https://gerrit.akraino.org/r/gitweb?p=validation.git;a=blobdiff_plain;f=ui%2Fsrc%2Fmain%2Fjava%2Forg%2Fakraino%2Fvalidation%2Fui%2Fconf%2FExecutorServiceInitializer.java;fp=ui%2Fsrc%2Fmain%2Fjava%2Forg%2Fakraino%2Fvalidation%2Fui%2Fconf%2FUiUtils.java;h=bfe4fc95339c88af33861c11261e5ab4211fea45;hp=7ef82345f1e5f16bfec4298d842923b45a7ff6de;hb=2eba847ebb6acb2686be08eb1cdafc1b12071e7d;hpb=f86b9715d156238532fcb0bf464bd72e9cf7ce96

diff --git a/ui/src/main/java/org/akraino/validation/ui/conf/UiUtils.java b/ui/src/main/java/org/akraino/validation/ui/conf/ExecutorServiceInitializer.java
similarity index 72%
rename from ui/src/main/java/org/akraino/validation/ui/conf/UiUtils.java
rename to ui/src/main/java/org/akraino/validation/ui/conf/ExecutorServiceInitializer.java
index 7ef8234..bfe4fc9 100644
--- a/ui/src/main/java/org/akraino/validation/ui/conf/UiUtils.java
+++ b/ui/src/main/java/org/akraino/validation/ui/conf/ExecutorServiceInitializer.java
@@ -22,23 +22,30 @@ import java.util.concurrent.PriorityBlockingQueue;
 import java.util.concurrent.ThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 
-public class UiUtils {
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+public class ExecutorServiceInitializer {
 
     private static final int QUEUE_CAPACITY = 500;
-    private static final int EXECUTOR_SIZE = 20; // the number of threads to keep in the pool, even if
+    private static final int EXECUTOR_SIZE = 30; // the number of threads to keep in the pool, even if
     // they are idle, unless allowCoreThreadTimeOut is
     // set
-    private static final int EXECUTOR_MAX_SIZE = 20; // the maximum number of threads to allow in the pool
-    private static final int KEEPALIVE_TIME = 20; // when the number of threads is greater than the
+    private static final int EXECUTOR_MAX_SIZE = 30; // the maximum number of threads to allow in the pool
+    private static final int KEEPALIVE_TIME = 30; // when the number of threads is greater than the
     // core, this is the maximum time that excess idle
     // threads will wait for new tasks before
     // terminating.
-    private static final PriorityBlockingQueue<Runnable> BLOCKING_QUEUE =
-            new PriorityBlockingQueue<Runnable>(QUEUE_CAPACITY, new CFRunnableComparator());
-    public static ExecutorService executorService =
-            new ThreadPoolExecutor(EXECUTOR_SIZE, EXECUTOR_MAX_SIZE, KEEPALIVE_TIME, TimeUnit.SECONDS, BLOCKING_QUEUE);
+    private static final PriorityBlockingQueue<Runnable> BLOCKING_QUEUE = new PriorityBlockingQueue<Runnable>(
+            QUEUE_CAPACITY, new CFRunnableComparator());
+    private static ExecutorService executorService = new ThreadPoolExecutor(EXECUTOR_SIZE, EXECUTOR_MAX_SIZE,
+            KEEPALIVE_TIME, TimeUnit.SECONDS, BLOCKING_QUEUE);
 
-    public static final String NEXUS_URL = "https://nexus.akraino.org/content/sites/logs";
+    @Bean(name = "executorService")
+    public ExecutorService getExecutorService() {
+        return this.executorService;
+    }
 
     private static class CFRunnableComparator implements Comparator<Runnable> {
         @Override