diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java b/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java index 99ead61c0..af43288f6 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/slot/Slot.java @@ -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 executeSteps = new ConcurrentLinkedQueue<>(); + private final Deque executeSteps = new ConcurrentLinkedDeque<>(); private String executeStepsStr; @@ -224,7 +225,7 @@ public class Slot{ return (String) metaDataMap.get(REQUEST_ID); } - public Queue getExecuteSteps() { + public Deque getExecuteSteps() { return executeSteps; }