public/liteFlow
1
0
Fork 0
mirror of https://gitee.com/dromara/liteFlow.git synced 2026-05-14 12:12:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

DataBus 性能优化 Lock Free

Browse Source
This commit is contained in:
王大锤
2021-05-19 16:10:44 +08:00
parent f1020b09e8
commit 6f5adc0675
1 changed files with 1 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

1
liteflow-core/src/main/java/com/yomahub/liteflow/entity/data/DataBus.java
View File

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