From 4deb840fdd922f3e3fbb4111adffeb3f16413f7c Mon Sep 17 00:00:00 2001
From: bryan31 <weenyc31@163.com>
Date: Thu, 18 Mar 2021 17:06:21 +0800
Subject: [PATCH] =?UTF-8?q?=E5=88=A0=E9=99=A4=E6=B2=A1=E7=94=A8=E7=9A=84?=
 =?UTF-8?q?=E5=86=85=E9=83=A8=E7=B1=BB?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../yomahub/liteflow/core/FlowExecutor.java   | 34 -------------------
 1 file changed, 34 deletions(-)

diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java b/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java
index 4cb99e1d1..9ef9297de 100644
--- a/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java
+++ b/liteflow-core/src/main/java/com/yomahub/liteflow/core/FlowExecutor.java
@@ -152,40 +152,6 @@ public class FlowExecutor {
 		return (T)slot;
 	}
 
-	private class WhenConditionThread extends Thread{
-
-		private Node node;
-
-		private Integer slotIndex;
-
-		private String requestId;
-
-		private CountDownLatch latch;
-
-		public WhenConditionThread(Node node,Integer slotIndex,String requestId,CountDownLatch latch){
-			this.node = node;
-			this.slotIndex = slotIndex;
-			this.requestId = requestId;
-			this.latch = latch;
-		}
-
-		@Override
-		public void run() {
-			try{
-				NodeComponent cmp = node.getInstance().setSlotIndex(slotIndex);
-				if(cmp.isAccess()) {
-					cmp.execute();
-				}else {
-					LOG.info("[{}]:[X]skip component[{}] execution",requestId,cmp.getClass().getSimpleName());
-				}
-			}catch(Exception e){
-				LOG.error("component [{}] execute cause error",node.getClazz(),e);
-			}finally{
-				latch.countDown();
-			}
-		}
-	}
-
 	public List<String> getRulePath() {
 		return rulePath;
 	}