From 7435a9742b8d30e098822a61b39a8ac030e40cbc Mon Sep 17 00:00:00 2001
From: bryan31 <weenyc31@163.com>
Date: Tue, 8 Mar 2022 00:52:39 +0800
Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E6=B5=8B=E8=AF=95=E7=94=A8?=
 =?UTF-8?q?=E4=BE=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../test/whenTimeOut/WhenTimeOutTest1.java    | 38 +++++++++++++++++++
 .../test/whenTimeOut/WhenTimeOutTest2.java    | 36 ++++++++++++++++++
 .../liteflow/test/whenTimeOut/cmp/ACmp.java   | 18 +++++++++
 .../liteflow/test/whenTimeOut/cmp/BCmp.java   | 24 ++++++++++++
 .../liteflow/test/whenTimeOut/cmp/CCmp.java   | 24 ++++++++++++
 .../liteflow/test/whenTimeOut/cmp/DCmp.java   | 24 ++++++++++++
 .../liteflow/test/whenTimeOut/cmp/ECmp.java   | 24 ++++++++++++
 .../liteflow/test/whenTimeOut/cmp/FCmp.java   | 24 ++++++++++++
 .../src/test/resources/whenTimeOut/flow1.xml  | 12 ++++++
 .../src/test/resources/whenTimeOut/flow2.xml  | 14 +++++++
 10 files changed, 238 insertions(+)
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest1.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest2.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ACmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/BCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/CCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/DCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ECmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/FCmp.java
 create mode 100644 liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow1.xml
 create mode 100644 liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow2.xml

diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest1.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest1.java
new file mode 100644
index 000000000..3182914fc
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest1.java
@@ -0,0 +1,38 @@
+package com.yomahub.liteflow.test.whenTimeOut;
+
+import com.yomahub.liteflow.core.FlowExecutor;
+import com.yomahub.liteflow.core.FlowExecutorHolder;
+import com.yomahub.liteflow.entity.data.DefaultSlot;
+import com.yomahub.liteflow.entity.data.LiteflowResponse;
+import com.yomahub.liteflow.exception.WhenTimeoutException;
+import com.yomahub.liteflow.property.LiteflowConfig;
+import com.yomahub.liteflow.test.BaseTest;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+/**
+ * 非spring环境下异步线程超时日志打印测试
+ * @author Bryan.Zhang
+ * @since 2.6.4
+ */
+public class WhenTimeOutTest1 extends BaseTest {
+
+    private static FlowExecutor flowExecutor;
+
+    @BeforeClass
+    public static void init(){
+        LiteflowConfig config = new LiteflowConfig();
+        config.setRuleSource("whenTimeOut/flow1.xml");
+        config.setWhenMaxWaitSeconds(3);
+        flowExecutor = FlowExecutorHolder.loadInstance(config);
+    }
+
+    //其中b和c在when情况下超时，所以抛出了WhenTimeoutException这个错
+    @Test
+    public void testWhenTimeOut() throws Exception{
+        LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain1", "arg");
+        Assert.assertFalse(response.isSuccess());
+        Assert.assertEquals(WhenTimeoutException.class, response.getCause().getClass());
+    }
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest2.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest2.java
new file mode 100644
index 000000000..e2b7e98f5
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/WhenTimeOutTest2.java
@@ -0,0 +1,36 @@
+package com.yomahub.liteflow.test.whenTimeOut;
+
+import com.yomahub.liteflow.core.FlowExecutor;
+import com.yomahub.liteflow.core.FlowExecutorHolder;
+import com.yomahub.liteflow.entity.data.DefaultSlot;
+import com.yomahub.liteflow.entity.data.LiteflowResponse;
+import com.yomahub.liteflow.property.LiteflowConfig;
+import com.yomahub.liteflow.test.BaseTest;
+import org.junit.Assert;
+import org.junit.BeforeClass;
+import org.junit.Test;
+
+/**
+ * 非spring环境下异步线程超时日志打印测试
+ * @author Bryan.Zhang
+ * @since 2.6.4
+ */
+public class WhenTimeOutTest2 extends BaseTest {
+
+    private static FlowExecutor flowExecutor;
+
+    @BeforeClass
+    public static void init(){
+        LiteflowConfig config = new LiteflowConfig();
+        config.setRuleSource("whenTimeOut/flow2.xml");
+        config.setWhenMaxWaitSeconds(5);
+        flowExecutor = FlowExecutorHolder.loadInstance(config);
+    }
+
+    //其中d,e,f都sleep 4秒，其中def是不同的组，超时设置5秒
+    @Test
+    public void testWhenTimeOut() throws Exception{
+        LiteflowResponse<DefaultSlot> response = flowExecutor.execute2Resp("chain1", "arg");
+        Assert.assertTrue(response.isSuccess());
+    }
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ACmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ACmp.java
new file mode 100644
index 000000000..f6faf4786
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ACmp.java
@@ -0,0 +1,18 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.whenTimeOut.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class ACmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		System.out.println("ACmp executed!");
+	}
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/BCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/BCmp.java
new file mode 100644
index 000000000..ba636d0e0
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/BCmp.java
@@ -0,0 +1,24 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.whenTimeOut.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class BCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		try {
+			Thread.sleep(4000);
+		}catch (Exception ignored){
+
+		}
+		System.out.println("BCmp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/CCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/CCmp.java
new file mode 100644
index 000000000..262415cca
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/CCmp.java
@@ -0,0 +1,24 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.whenTimeOut.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class CCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		try {
+			Thread.sleep(3500);
+		}catch (Exception ignored){
+
+		}
+		System.out.println("CCmp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/DCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/DCmp.java
new file mode 100644
index 000000000..b40df5d0a
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/DCmp.java
@@ -0,0 +1,24 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.whenTimeOut.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class DCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		try {
+			Thread.sleep(4000);
+		}catch (Exception ignored){
+
+		}
+		System.out.println("DCmp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ECmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ECmp.java
new file mode 100644
index 000000000..8136cb1c5
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/ECmp.java
@@ -0,0 +1,24 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.whenTimeOut.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class ECmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		try {
+			Thread.sleep(4000);
+		}catch (Exception ignored){
+
+		}
+		System.out.println("ECmp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/FCmp.java b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/FCmp.java
new file mode 100644
index 000000000..2b96487cc
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/java/com/yomahub/liteflow/test/whenTimeOut/cmp/FCmp.java
@@ -0,0 +1,24 @@
+/**
+ * <p>Title: liteflow</p>
+ * <p>Description: 轻量级的组件式流程框架</p>
+ * @author Bryan.Zhang
+ * @email weenyc31@163.com
+ * @Date 2020/4/1
+ */
+package com.yomahub.liteflow.test.whenTimeOut.cmp;
+
+import com.yomahub.liteflow.core.NodeComponent;
+
+public class FCmp extends NodeComponent {
+
+	@Override
+	public void process() {
+		try {
+			Thread.sleep(4000);
+		}catch (Exception ignored){
+
+		}
+		System.out.println("FCmp executed!");
+	}
+
+}
diff --git a/liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow1.xml b/liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow1.xml
new file mode 100644
index 000000000..e3ac01d8a
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow1.xml
@@ -0,0 +1,12 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<flow>
+    <nodes>
+        <node id="a" class="com.yomahub.liteflow.test.whenTimeOut.cmp.ACmp"/>
+        <node id="b" class="com.yomahub.liteflow.test.whenTimeOut.cmp.BCmp"/>
+        <node id="c" class="com.yomahub.liteflow.test.whenTimeOut.cmp.CCmp"/>
+    </nodes>
+
+    <chain name="chain1">
+        <when value="a,b,c"/>
+    </chain>
+</flow>
\ No newline at end of file
diff --git a/liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow2.xml b/liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow2.xml
new file mode 100644
index 000000000..1f889c1fe
--- /dev/null
+++ b/liteflow-testcase-nospring/src/test/resources/whenTimeOut/flow2.xml
@@ -0,0 +1,14 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<flow>
+    <nodes>
+        <node id="d" class="com.yomahub.liteflow.test.whenTimeOut.cmp.DCmp"/>
+        <node id="e" class="com.yomahub.liteflow.test.whenTimeOut.cmp.ECmp"/>
+        <node id="f" class="com.yomahub.liteflow.test.whenTimeOut.cmp.FCmp"/>
+    </nodes>
+
+    <chain name="chain1">
+        <when value="d" group="1"/>
+        <when value="e" group="2"/>
+        <when value="f" group="3"/>
+    </chain>
+</flow>
\ No newline at end of file