diff --git a/liteflow-benchmark/liteflow-benchmark-common/src/test/java/com/yomahub/liteflow/benchmark/CommonBenchmark.java b/liteflow-benchmark/liteflow-benchmark-common/src/test/java/com/yomahub/liteflow/benchmark/CommonBenchmark.java index 7d770b5dd..6fb2d746b 100644 --- a/liteflow-benchmark/liteflow-benchmark-common/src/test/java/com/yomahub/liteflow/benchmark/CommonBenchmark.java +++ b/liteflow-benchmark/liteflow-benchmark-common/src/test/java/com/yomahub/liteflow/benchmark/CommonBenchmark.java @@ -50,6 +50,11 @@ public class CommonBenchmark { flowExecutor.execute2Resp("chain2"); } + @Benchmark + public void test3(){ + flowExecutor.execute2Resp("chain3"); + } + public static void main(String[] args) throws RunnerException { Options opt = new OptionsBuilder() diff --git a/liteflow-benchmark/liteflow-benchmark-common/src/test/java/com/yomahub/liteflow/benchmark/cmp/DCmp.java b/liteflow-benchmark/liteflow-benchmark-common/src/test/java/com/yomahub/liteflow/benchmark/cmp/DCmp.java new file mode 100644 index 000000000..35ee84388 --- /dev/null +++ b/liteflow-benchmark/liteflow-benchmark-common/src/test/java/com/yomahub/liteflow/benchmark/cmp/DCmp.java @@ -0,0 +1,15 @@ +package com.yomahub.liteflow.benchmark.cmp; + +import cn.hutool.core.collection.ListUtil; +import com.yomahub.liteflow.annotation.LiteflowComponent; +import com.yomahub.liteflow.core.NodeIteratorComponent; + +import java.util.Iterator; + +@LiteflowComponent("d") +public class DCmp extends NodeIteratorComponent { + @Override + public Iterator processIterator() throws Exception { + return ListUtil.toList("1","2","3").iterator(); + } +} diff --git a/liteflow-benchmark/liteflow-benchmark-common/src/test/resources/application.properties b/liteflow-benchmark/liteflow-benchmark-common/src/test/resources/application.properties index 55dc0b1ec..deb56e3f8 100644 --- a/liteflow-benchmark/liteflow-benchmark-common/src/test/resources/application.properties +++ b/liteflow-benchmark/liteflow-benchmark-common/src/test/resources/application.properties @@ -1,2 +1,5 @@ liteflow.rule-source=flow.xml -liteflow.print-execution-log=false \ No newline at end of file +liteflow.print-execution-log=false + +liteflow.global-thread-pool-size=500 +liteflow.global-thread-pool-queue-size=1000 \ No newline at end of file diff --git a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/parallelLoop/ParallelLoopELSpringbootTest.java b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/parallelLoop/ParallelLoopELSpringbootTest.java index 9332d19e6..3724d5259 100644 --- a/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/parallelLoop/ParallelLoopELSpringbootTest.java +++ b/liteflow-testcase-el/liteflow-testcase-el-springboot/src/test/java/com/yomahub/liteflow/test/parallelLoop/ParallelLoopELSpringbootTest.java @@ -38,8 +38,12 @@ public class ParallelLoopELSpringbootTest extends BaseTest { //测试并行FOR循环,循环次数直接在el中定义 @Test public void testParallelLoop1() throws Exception { - LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg"); - Assertions.assertTrue(response.isSuccess()); + + for (int i = 0; i < 10; i++) { + LiteflowResponse response = flowExecutor.execute2Resp("chain1", "arg"); + Assertions.assertTrue(response.isSuccess()); + } + } //测试并行FOR循环,循环次数由For组件定义