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;h=bb87a7c9fadf5ec5c195d6408933fa7ab761e50f;hb=917e6436721c3cf0075ab1abacb5f7bc0e4732a9;hp=058e7459ec0593b023ec4502568095a2901b554c;hpb=bf6ffaf6e08b066da8bc69ab7b478d8b5528ce21;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
index 058e745..bb87a7c 100644
--- 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
@@ -16,39 +16,25 @@
  * ===============LICENSE_END=======================================================================
  */
 
-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();
-  // }
-}
+package org.commscope.tr069adapter.vesagent.async;
+
+import java.util.concurrent.Executor;
+import java.util.concurrent.Executors;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.annotation.EnableAsync;
+
+@Configuration
+@EnableAsync
+public class AsyncThreadPoolConfig {
+
+  @Bean(name = "threadPoolTaskExecutor1")
+  public Executor threadPoolTaskExecutor() {
+    return Executors.newFixedThreadPool(50);
+  }
+
+  @Bean(name = "threadPoolTaskExecutor2")
+  public Executor threadPoolTaskExecutor2() {
+    return Executors.newFixedThreadPool(50);
+  }
+}