From f49dcc1727f18c4cc13cd5aa6f457722bf47c6c0 Mon Sep 17 00:00:00 2001 From: Timo Bejan Date: Wed, 31 Jan 2024 10:07:05 +0100 Subject: [PATCH] Fixed pool sizes --- src/main/resources/tenant-commons-task.properties | 6 +++--- .../knecon/fforesight/tenantcommons/TaskExecutionTest.java | 6 +++--- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/src/main/resources/tenant-commons-task.properties b/src/main/resources/tenant-commons-task.properties index 53bc191..9185068 100644 --- a/src/main/resources/tenant-commons-task.properties +++ b/src/main/resources/tenant-commons-task.properties @@ -4,7 +4,7 @@ # For more available props, # see: https://github.com/spring-projects/spring-boot/blob/main/spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/task/TaskExecutionProperties.java # -spring.task.execution.pool.coreSize=7 -spring.task.execution.pool.maxSize=42 -spring.task.execution.pool.queueCapacity=11 +spring.task.execution.pool.coreSize=4 +spring.task.execution.pool.maxSize=4 +spring.task.execution.pool.queueCapacity=10000 spring.task.execution.threadNamePrefix=TenantAwareTaskExecutor- diff --git a/src/test/java/com/knecon/fforesight/tenantcommons/TaskExecutionTest.java b/src/test/java/com/knecon/fforesight/tenantcommons/TaskExecutionTest.java index 999997e..5aa44a6 100644 --- a/src/test/java/com/knecon/fforesight/tenantcommons/TaskExecutionTest.java +++ b/src/test/java/com/knecon/fforesight/tenantcommons/TaskExecutionTest.java @@ -32,9 +32,9 @@ public class TaskExecutionTest { assertThat(taskExecutor).isNotNull(); assertThat(taskExecutor).isInstanceOf(ThreadPoolTaskExecutor.class); if (taskExecutor instanceof ThreadPoolTaskExecutor threadPoolTaskExecutor) { - assertThat(threadPoolTaskExecutor.getCorePoolSize()).isEqualTo(7); - assertThat(threadPoolTaskExecutor.getMaxPoolSize()).isEqualTo(42); - assertThat(threadPoolTaskExecutor.getQueueCapacity()).isEqualTo(11); + assertThat(threadPoolTaskExecutor.getCorePoolSize()).isEqualTo(4); + assertThat(threadPoolTaskExecutor.getMaxPoolSize()).isEqualTo(4); + assertThat(threadPoolTaskExecutor.getQueueCapacity()).isEqualTo(10_000); assertThat(threadPoolTaskExecutor.getThreadNamePrefix()).isEqualTo("TenantAwareTaskExecutor-"); } });