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

bug PercentageOfParallelExecutor 中任务收集列表指定初始值，避免不必要的扩容；复原其他测试案例

Browse Source
This commit is contained in:
luoyi
2025-07-15 13:37:18 +08:00
parent c5052b1ef3
commit d342a08af5
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/flow/parallel/strategy/PercentageOfParallelExecutor.java
View File

@@ -29,7 +29,7 @@ public class PercentageOfParallelExecutor extends ParallelStrategyExecutor {
int thresholdCount = (int) Math.ceil(total * whenCondition.getPercentage());
// 已完成任务收集器（对 List 加锁保证线程安全）
List<CompletableFuture<WhenFutureObj>> completedFutures = Collections.synchronizedList(new ArrayList<>(thresholdCount));
List<CompletableFuture<WhenFutureObj>> completedFutures = Collections.synchronizedList(new ArrayList<>(Math.max(thresholdCount, 1) << 1));
// 阈值触发门闩
CompletableFuture<Void> thresholdFuture = new CompletableFuture<>();