From 20c760bb31feacb567de48e7df0b205bf836b575 Mon Sep 17 00:00:00 2001 From: bryan31 Date: Thu, 11 Nov 2021 13:19:46 +0800 Subject: [PATCH] =?UTF-8?q?bug=20#I4HTY6=20=E5=BC=82=E6=AD=A5=E7=BA=BF?= =?UTF-8?q?=E7=A8=8B=E6=B1=A0=E4=B8=8D=E5=8F=97=E9=85=8D=E7=BD=AE=E6=8E=A7?= =?UTF-8?q?=E5=88=B6=E7=9A=84bug=EF=BC=8C=E4=B8=80=E7=9B=B4=E6=98=AF?= =?UTF-8?q?=E9=BB=98=E8=AE=A4=E7=9A=84=E6=95=B0=E9=87=8F?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../springboot/config/LiteflowExecutorAutoConfiguration.java | 3 +++ .../liteflow/test/config/LiteflowConfigSpringbootTest.java | 2 +- 2 files changed, 4 insertions(+), 1 deletion(-) diff --git a/liteflow-spring-boot-starter/src/main/java/com/yomahub/liteflow/springboot/config/LiteflowExecutorAutoConfiguration.java b/liteflow-spring-boot-starter/src/main/java/com/yomahub/liteflow/springboot/config/LiteflowExecutorAutoConfiguration.java index 75879aa0e..f87967171 100644 --- a/liteflow-spring-boot-starter/src/main/java/com/yomahub/liteflow/springboot/config/LiteflowExecutorAutoConfiguration.java +++ b/liteflow-spring-boot-starter/src/main/java/com/yomahub/liteflow/springboot/config/LiteflowExecutorAutoConfiguration.java @@ -3,11 +3,13 @@ package com.yomahub.liteflow.springboot.config; import com.yomahub.liteflow.property.LiteflowConfig; import com.yomahub.liteflow.util.ExecutorHelper; import com.yomahub.liteflow.util.LiteFlowExecutorPoolShutdown; +import com.yomahub.liteflow.util.SpringAware; import org.springframework.boot.autoconfigure.AutoConfigureAfter; import org.springframework.boot.autoconfigure.condition.ConditionalOnBean; import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; +import org.springframework.context.annotation.Import; import java.util.concurrent.ExecutorService; @@ -20,6 +22,7 @@ import java.util.concurrent.ExecutorService; @AutoConfigureAfter({LiteflowPropertyAutoConfiguration.class}) @ConditionalOnProperty(prefix = "liteflow", name = "enable", havingValue = "true") @ConditionalOnBean(LiteflowConfig.class) +@Import(SpringAware.class) public class LiteflowExecutorAutoConfiguration { @Bean("whenExecutors") diff --git a/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringbootTest.java b/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringbootTest.java index bd80d2f7c..f79c99382 100644 --- a/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringbootTest.java +++ b/liteflow-testcase-springboot/src/test/java/com/yomahub/liteflow/test/config/LiteflowConfigSpringbootTest.java @@ -46,7 +46,7 @@ public class LiteflowConfigSpringbootTest extends BaseTest { Assert.assertEquals(300000L, config.getDelay().longValue()); Assert.assertEquals(300000L, config.getPeriod().longValue()); Assert.assertFalse(config.getEnableLog()); - Assert.assertEquals(4, config.getWhenMaxWorkers().longValue()); + Assert.assertEquals(16, config.getWhenMaxWorkers().longValue()); Assert.assertEquals(512, config.getWhenQueueLimit().longValue()); Assert.assertEquals(true, config.isParseOnStart()); }