| Package | Description |
|---|---|
| com.yomahub.liteflow.builder.el.operator | |
| com.yomahub.liteflow.flow.element.condition | |
| com.yomahub.liteflow.flow.parallel.strategy |
| Modifier and Type | Method and Description |
|---|---|
WhenCondition |
MustOperator.build(Object[] objects) |
WhenCondition |
WhenOperator.build(Object[] objects) |
WhenCondition |
AnyOperator.build(Object[] objects) |
WhenCondition |
IgnoreErrorOperator.build(Object[] objects) |
WhenCondition |
PercentageOperator.build(Object[] objects) |
| Modifier and Type | Class and Description |
|---|---|
class |
TimeoutCondition
超时控制 Condition
|
| Modifier and Type | Method and Description |
|---|---|
void |
SpecifyParallelExecutor.execute(WhenCondition whenCondition,
Integer slotIndex) |
void |
PercentageOfParallelExecutor.execute(WhenCondition whenCondition,
Integer slotIndex) |
void |
AnyOfParallelExecutor.execute(WhenCondition whenCondition,
Integer slotIndex) |
void |
AllOfParallelExecutor.execute(WhenCondition whenCondition,
Integer slotIndex) |
abstract void |
ParallelStrategyExecutor.execute(WhenCondition whenCondition,
Integer slotIndex) |
protected List<CompletableFuture<WhenFutureObj>> |
ParallelStrategyExecutor.getWhenAllTaskList(WhenCondition whenCondition,
Integer slotIndex)
获取所有任务 CompletableFuture 集合
|
protected void |
ParallelStrategyExecutor.handleTaskResult(WhenCondition whenCondition,
Integer slotIndex,
List<CompletableFuture<WhenFutureObj>> whenAllFutureList,
CompletableFuture<?> specifyTask)
任务结果处理
|
protected void |
ParallelStrategyExecutor.setWhenConditionParams(WhenCondition whenCondition)
设置 WhenCondition 参数
|
protected CompletableFuture<WhenFutureObj> |
ParallelStrategyExecutor.wrappedFutureObj(Executable executable,
ExecutorService parallelExecutor,
WhenCondition whenCondition,
String currChainId,
Integer slotIndex)
封装 CompletableFuture 对象
|
Copyright © 2025. All rights reserved.