From 6f5adc0675b30fae233c3cb526f1e5fd9901e86a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E7=8E=8B=E5=A4=A7=E9=94=A4?= <ibatdream@qq.com>
Date: Wed, 19 May 2021 16:10:44 +0800
Subject: [PATCH] =?UTF-8?q?DataBus=20=E6=80=A7=E8=83=BD=E4=BC=98=E5=8C=96?=
 =?UTF-8?q?=20Lock=20Free?=
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  | 1 +
 1 file changed, 1 insertion(+)

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);