X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=ves-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Fvesagent%2Fasync%2FAsyncThreadPoolConfig.java;fp=ves-agent%2Fsrc%2Fmain%2Fjava%2Forg%2Fcommscope%2Ftr069adapter%2Fvesagent%2Fasync%2FAsyncThreadPoolConfig.java;h=b968608d0fcdbd774ab53d38eddd6d87064226fe;hb=641a6c47b4ee74412e9386b3c95693adda3cafc9;hp=0000000000000000000000000000000000000000;hpb=8c7432b8380a355e89df05f070e7d88e599912fd;p=oam%2Ftr069-adapter.git

diff --git a/ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/async/AsyncThreadPoolConfig.java b/ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/async/AsyncThreadPoolConfig.java
new file mode 100644
index 0000000..b968608
--- /dev/null
+++ b/ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/async/AsyncThreadPoolConfig.java
@@ -0,0 +1,36 @@
+package org.commscope.tr069adapter.vesagent.async;
+
+import java.util.concurrent.Executor;
+
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.AsyncConfigurer;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
+
+/**
+ * 
+ * @version 1.0
+ * @since June 12, 2020
+ * @author Prashant Kumar
+ */
+
+@Configuration
+@EnableAsync
+public class AsyncThreadPoolConfig implements AsyncConfigurer {
+
+  @Override
+  public Executor getAsyncExecutor() {
+    ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
+    executor.setCorePoolSize(7);
+    executor.setMaxPoolSize(25);
+    executor.setQueueCapacity(11);
+    executor.setThreadNamePrefix("MyExecutor-");
+    executor.initialize();
+    return executor;
+  }
+
+  // @Override
+  // public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {
+  // return new MyAsyncUncaughtExceptionHandler();
+  // }
+}