From fa63fae6fc1bbada980db4b0a1af626e23f79e93 Mon Sep 17 00:00:00 2001 From: tschiman Date: Wed, 11 Jan 2017 21:59:38 -0700 Subject: [PATCH] BAEL-442 Making some changes to how many threads are in the executors. Cleaning up some white space. --- .../spring/session/SleuthController.java | 3 --- .../baeldung/spring/session/ThreadConfig.java | 27 +++++++++---------- 2 files changed, 13 insertions(+), 17 deletions(-) diff --git a/spring-sleuth/src/main/java/com/baeldung/spring/session/SleuthController.java b/spring-sleuth/src/main/java/com/baeldung/spring/session/SleuthController.java index eeaed15bea..ada1152a4e 100644 --- a/spring-sleuth/src/main/java/com/baeldung/spring/session/SleuthController.java +++ b/spring-sleuth/src/main/java/com/baeldung/spring/session/SleuthController.java @@ -65,7 +65,4 @@ public class SleuthController { logger.info("After Async Method Call"); return "success"; } - - - } diff --git a/spring-sleuth/src/main/java/com/baeldung/spring/session/ThreadConfig.java b/spring-sleuth/src/main/java/com/baeldung/spring/session/ThreadConfig.java index 56cabee443..650be70f19 100644 --- a/spring-sleuth/src/main/java/com/baeldung/spring/session/ThreadConfig.java +++ b/spring-sleuth/src/main/java/com/baeldung/spring/session/ThreadConfig.java @@ -25,12 +25,22 @@ public class ThreadConfig extends AsyncConfigurerSupport implements SchedulingCo @Bean public Executor executor() { - return makeExecutor(); + ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor(); + threadPoolTaskExecutor.setCorePoolSize(1); + threadPoolTaskExecutor.setMaxPoolSize(1); + threadPoolTaskExecutor.initialize(); + + return new LazyTraceExecutor(beanFactory, threadPoolTaskExecutor); } @Override public Executor getAsyncExecutor() { - return makeExecutor(); + ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor(); + threadPoolTaskExecutor.setCorePoolSize(1); + threadPoolTaskExecutor.setMaxPoolSize(1); + threadPoolTaskExecutor.initialize(); + + return new LazyTraceExecutor(beanFactory, threadPoolTaskExecutor); } @Override @@ -40,17 +50,6 @@ public class ThreadConfig extends AsyncConfigurerSupport implements SchedulingCo @Bean(destroyMethod = "shutdown") public Executor schedulingExecutor() { - return Executors.newScheduledThreadPool(100); + return Executors.newScheduledThreadPool(1); } - - private Executor makeExecutor() { - ThreadPoolTaskExecutor threadPoolTaskExecutor = new ThreadPoolTaskExecutor(); - threadPoolTaskExecutor.setCorePoolSize(5); - threadPoolTaskExecutor.setMaxPoolSize(10); - threadPoolTaskExecutor.initialize(); - - return new LazyTraceExecutor(beanFactory, threadPoolTaskExecutor); - } - - }