From a8e02d9fd892fa1dad32eff99d9635b34102cc0b Mon Sep 17 00:00:00 2001 From: bryan31 Date: Sat, 18 Sep 2021 19:15:51 +0800 Subject: [PATCH] =?UTF-8?q?enhancement=20#I49JP1=20DataBus=E4=B8=ADSlotSiz?= =?UTF-8?q?e=E7=9A=84=E5=A4=A7=E5=B0=8F=E4=B8=8D=E6=94=AF=E6=8C=81?= =?UTF-8?q?=E5=8A=A8=E6=80=81=E6=89=A9=E5=B1=95=EF=BC=8C=E6=97=A0=E6=B3=95?= =?UTF-8?q?=E5=BA=94=E5=AF=B9=E9=AB=98=E5=B9=B6=E5=8F=91=E4=B8=8B=E7=9A=84?= =?UTF-8?q?=E6=B5=81=E9=87=8F=E7=AA=81=E5=A2=9E?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/yomahub/liteflow/entity/data/DataBus.java | 4 ++++ 1 file changed, 4 insertions(+) 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 95f37657e..7c37f6f21 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 @@ -52,6 +52,10 @@ public class DataBus { public static int offerSlot(Class slotClazz) { try { Slot slot = slotClazz.newInstance(); + + //这里有没有并发问题？ + //没有，因为QUEUE的类型为ConcurrentLinkedQueue，并发情况下，每次取到的index不会相同 + //当然前提是QUEUE里面的值不会重复，但是这个是由其他机制来保证的 Integer slotIndex = QUEUE.poll(); if (ObjectUtil.isNull(slotIndex)){