增加benchmark的示例代码

This commit is contained in:
everywhere.z
2024-12-20 12:13:13 +08:00
parent dda3172b1f
commit b19f3681ca
4 changed files with 30 additions and 3 deletions

View File

@@ -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()

View File

@@ -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();
}
}

View File

@@ -1,2 +1,5 @@
liteflow.rule-source=flow.xml
liteflow.print-execution-log=false
liteflow.global-thread-pool-size=500
liteflow.global-thread-pool-queue-size=1000

View File

@@ -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组件定义