* ===============LICENSE_END=======================================================================
*/
-package org.commscope.tr069adapter.vesagent.async;\r
-\r
-import java.util.concurrent.Executor;\r
-\r
-import org.springframework.context.annotation.Configuration;\r
-import org.springframework.scheduling.annotation.AsyncConfigurer;\r
-import org.springframework.scheduling.annotation.EnableAsync;\r
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;\r
-\r
-/**\r
- * \r
- * @version 1.0\r
- * @since June 12, 2020\r
- * @author Prashant Kumar\r
- */\r
-\r
-@Configuration\r
-@EnableAsync\r
-public class AsyncThreadPoolConfig implements AsyncConfigurer {\r
-\r
- @Override\r
- public Executor getAsyncExecutor() {\r
- ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();\r
- executor.setCorePoolSize(7);\r
- executor.setMaxPoolSize(25);\r
- executor.setQueueCapacity(11);\r
- executor.setThreadNamePrefix("MyExecutor-");\r
- executor.initialize();\r
- return executor;\r
- }\r
-\r
- // @Override\r
- // public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {\r
- // return new MyAsyncUncaughtExceptionHandler();\r
- // }\r
-}\r
+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);
+ }
+}