From ebfd4abdd0b1369be04d8e13a7fe85dfd7176761 Mon Sep 17 00:00:00 2001 From: caiyp Date: Wed, 27 Jul 2022 18:09:33 +0800 Subject: [PATCH] =?UTF-8?q?#I5J8BC=20=E8=B0=83=E6=95=B4Slot.executeSteps?= =?UTF-8?q?=E7=B1=BB=E5=9E=8BQueue=20->=20Deque?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/yomahub/liteflow/slot/Slot.java | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) 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; }