ves-agent/src/main/java/org/commscope/tr069adapter/vesagent/async/AsyncThreadPoolConfig.java

   1 package org.commscope.tr069adapter.vesagent.async;\r
   2 \r
   3 import java.util.concurrent.Executor;\r
   4 \r
   5 import org.springframework.context.annotation.Configuration;\r
   6 import org.springframework.scheduling.annotation.AsyncConfigurer;\r
   7 import org.springframework.scheduling.annotation.EnableAsync;\r
   8 import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;\r
   9 \r
  10 /**\r
  11  * \r
  12  * @version 1.0\r
  13  * @since June 12, 2020\r
  14  * @author Prashant Kumar\r
  15  */\r
  16 \r
  17 @Configuration\r
  18 @EnableAsync\r
  19 public class AsyncThreadPoolConfig implements AsyncConfigurer {\r
  20 \r
  21   @Override\r
  22   public Executor getAsyncExecutor() {\r
  23     ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();\r
  24     executor.setCorePoolSize(7);\r
  25     executor.setMaxPoolSize(25);\r
  26     executor.setQueueCapacity(11);\r
  27     executor.setThreadNamePrefix("MyExecutor-");\r
  28     executor.initialize();\r
  29     return executor;\r
  30   }\r
  31 \r
  32   // @Override\r
  33   // public AsyncUncaughtExceptionHandler getAsyncUncaughtExceptionHandler() {\r
  34   // return new MyAsyncUncaughtExceptionHandler();\r
  35   // }\r
  36 }\r