com.yomahub.liteflow.flow.parallel.strategy

Class AllOfParallelExecutor

java.lang.Object

com.yomahub.liteflow.flow.parallel.strategy.ParallelStrategyExecutor

com.yomahub.liteflow.flow.parallel.strategy.AllOfParallelExecutor

public class AllOfParallelExecutor
extends ParallelStrategyExecutor

完成全部任务

Since:

2.11.0

Author:

luo yi, Bryan.Zhang

Field Summary

Fields inherited from class com.yomahub.liteflow.flow.parallel.strategy.ParallelStrategyExecutor

LOG

Constructor Summary

Constructors

Constructor and Description
AllOfParallelExecutor()

Method Summary

Modifier and Type	Method and Description
void	execute(WhenCondition whenCondition, Integer slotIndex)
protected Stream<Executable>	filterAccess(Stream<Executable> stream, Integer slotIndex, String currentChainId)

Methods inherited from class com.yomahub.liteflow.flow.parallel.strategy.ParallelStrategyExecutor

filterWhenTaskList, getWhenAllTaskList, handleTaskResult, setWhenConditionParams, wrappedFutureObj

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AllOfParallelExecutor

public AllOfParallelExecutor()

Method Detail

execute

public void execute(WhenCondition whenCondition,
                    Integer slotIndex)
             throws Exception

Specified by:

execute in class ParallelStrategyExecutor

Throws:

Exception

filterAccess

protected Stream<Executable> filterAccess(Stream<Executable> stream,
                                          Integer slotIndex,
                                          String currentChainId)

Overrides:

filterAccess in class ParallelStrategyExecutor