From 88a475a972b2f9edab3089730c1a141278589458 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=AF=B7=E5=8F=AB=E6=88=91=E7=8C=BF=E5=8F=94=E5=8F=94?= <1956025812@qq.com> Date: Fri, 10 Sep 2021 20:19:24 +0800 Subject: [PATCH] =?UTF-8?q?issue:=20https://gitee.com/dromara/liteFlow/iss?= =?UTF-8?q?ues/I49L1S=20=E5=88=9D=E5=A7=8B=E5=8C=96DataBus=E7=9A=84QUEUE?= =?UTF-8?q?=E7=9A=84=E6=97=B6=E5=80=99=EF=BC=8CIntStream.range=E6=98=AF?= =?UTF-8?q?=E5=B7=A6=E9=97=AD=E5=8F=B3=E5=BC=80=E5=8C=BA=E9=97=B4=E7=9A=84?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=EF=BC=8C=E4=B8=8D=E9=9C=80=E8=A6=81=E5=87=8F?= =?UTF-8?q?=E4=B8=80=EF=BC=8C=E5=90=A6=E5=88=99=E5=9C=A8=E4=B8=B4=E7=95=8C?= =?UTF-8?q?=E5=80=BC=E4=BC=9A=E4=B8=A2=E5=A4=B1slotIndex?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../src/main/java/com/yomahub/liteflow/entity/data/DataBus.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/DataBus.java b/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/DataBus.java index 8aba0fc65..a03156f35 100644 --- a/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/DataBus.java +++ b/liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/DataBus.java @@ -38,7 +38,7 @@ public class DataBus { LiteflowConfig liteflowConfig = LiteflowConfigGetter.get(); int slotSize = liteflowConfig.getSlotSize(); SLOTS = new AtomicReferenceArray<>(slotSize); - QUEUE = IntStream.range(0, slotSize - 1).boxed().collect(Collectors.toCollection(ConcurrentLinkedQueue::new)); + QUEUE = IntStream.range(0, slotSize).boxed().collect(Collectors.toCollection(ConcurrentLinkedQueue::new)); } public static int offerSlot(Class slotClazz) {