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

!29 修复issue: I49L1S [初始化DataBus的数据槽索引QUEUE大小的时候容量设置有问题]

Browse Source 
Merge pull request !29 from 请叫我猿叔叔/bugfix-I49L1S-slotsizeinit
This commit is contained in:
铂赛东
2021-09-10 13:46:29 +00:00
committed by Gitee
parent 5cb2932188 88a475a972
commit 0f847a1888
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -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<? extends Slot> slotClazz) {