public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-15 04:22:09 +08:00
Code Issues Packages Projects Releases Wiki Activity

#I5J8BC 调整Slot.executeSteps类型Queue -> Deque

Browse Source
This commit is contained in:
caiyp
2022-07-27 18:09:33 +08:00
parent f05329c792
commit ebfd4abdd0
1 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java
View File

@@ -16,11 +16,12 @@ import com.yomahub.liteflow.flow.id.IdGeneratorHolder;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.util.Deque;
import java.util.Iterator;
import java.util.List;
import java.util.Queue;
import java.util.Stack;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentLinkedDeque;
import java.util.concurrent.ConcurrentLinkedQueue;
/**
@@ -53,7 +54,7 @@ public class Slot{
private static final String PRIVATE_DELIVERY_PREFIX = "_private_d_";
private final Queue<CmpStep> executeSteps = new ConcurrentLinkedQueue<>();
private final Deque<CmpStep> executeSteps = new ConcurrentLinkedDeque<>();
private String executeStepsStr;
@@ -224,7 +225,7 @@ public class Slot{
return (String) metaDataMap.get(REQUEST_ID);
}
public Queue<CmpStep> getExecuteSteps() {
public Deque<CmpStep> getExecuteSteps() {
return executeSteps;
}