task pool size from properties

Author: gy2006

core/src/main/java/com/flowci/core/common/config/AppConfig.java

@@ -34,6 +34,7 @@
 import org.springframework.core.ResolvableType;
 import org.springframework.core.task.TaskExecutor;
 import org.springframework.scheduling.annotation.EnableScheduling;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 import javax.annotation.PostConstruct;
 import java.io.IOException;
@@ -80,8 +81,10 @@ public ObjectMapper objectMapper() {
     }
 
     @Bean("appTaskExecutor")
-    public TaskExecutor getAppTaskExecutor() {
-        return ThreadHelper.createTaskExecutor(100, 100, 50, "app-task-");
+    public ThreadPoolTaskExecutor getAppTaskExecutor() {
+        int corePoolSize = appProperties.getCorePoolSize();
+        int maxPoolSize = appProperties.getMaxPoolSize();
+        return ThreadHelper.createTaskExecutor(maxPoolSize, corePoolSize, 10, "app-task-");
     }
 
     @Bean(name = "applicationEventMulticaster")

core/src/main/java/com/flowci/core/common/config/AppProperties.java

@@ -57,6 +57,10 @@ public class AppProperties {
 
     private boolean socketContainer;
 
+    private int corePoolSize;
+
+    private int maxPoolSize;
+
     @Bean("zkProperties")
     @ConfigurationProperties(prefix = "app.zookeeper")
     public Zookeeper zk() {

core/src/main/resources/flow.properties

@@ -5,6 +5,8 @@ app.secret=${FLOWCI_SECRET:qazWSXedcRFV12#$}
 app.auto-local-agent-host=${FLOWCI_AUTO_AGENT:true}
 app.default-smtp-config=true
 app.socket-container=true
+app.core-pool-size=100
+app.max-pool-size=200
 
 app.auth.enabled=true
 app.auth.expire-seconds=7200

core/src/test/resources/flow.properties

@@ -5,6 +5,8 @@ app.secret=qazWSXedcRFV12#$
 app.auto-local-agent-host=false
 app.default-smtp-config=false
 app.socket-container=false
+app.core-pool-size=100
+app.max-pool-size=200
 
 app.auth.enabled=false
 app.auth.expire-seconds=5