mirror of
https://gitee.com/dromara/liteFlow.git
synced 2026-05-14 12:12:08 +08:00
删除没用的内部类
This commit is contained in:
@@ -152,40 +152,6 @@ public class FlowExecutor {
|
|||||||
return (T)slot;
|
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() {
|
public List<String> getRulePath() {
|
||||||
return rulePath;
|
return rulePath;
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user