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 422ceb86a..ccc87bfe1 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 @@ -71,6 +71,7 @@ public class DataBus { if(ObjectUtil.isNotNull(SLOTS.get(slotIndex))){ LOG.info("[{}]:slot[{}] released",SLOTS.get(slotIndex).getRequestId(),slotIndex); SLOTS.set(slotIndex, null); + QUEUE.add(slotIndex); OCCUPY_COUNT.decrementAndGet(); }else{ LOG.warn("slot[{}] already has been released",slotIndex);