类的使用
cn.feiliu.taskflow.sdk.workflow.def.tasks.Task

使用Task的程序包

程序包	说明
cn.feiliu.taskflow.common.metadata.workflow
cn.feiliu.taskflow.sdk.workflow.def
cn.feiliu.taskflow.sdk.workflow.def.tasks

cn.feiliu.taskflow.common.metadata.workflow中Task的使用

参数类型为Task的cn.feiliu.taskflow.common.metadata.workflow中的方法

修饰符和类型	方法	说明
WorkflowDefinition.Builder	WorkflowDefinition.Builder.addTask(Task task)

类型变量类型为Task的cn.feiliu.taskflow.common.metadata.workflow中的方法参数

修饰符和类型	方法	说明
WorkflowDefinition.Builder	WorkflowDefinition.Builder.tasks(List<Task> tasks)

cn.feiliu.taskflow.sdk.workflow.def中Task的使用

参数类型为Task的cn.feiliu.taskflow.sdk.workflow.def中的方法

修饰符和类型	方法	说明
LoopTask	ILoopTask.childTask(Task<?> task)	添加子任务
default LoopTask	ILoopTask.childTasks(Task<?>... tasks)	批量添加子任务

cn.feiliu.taskflow.sdk.workflow.def.tasks中Task的使用

cn.feiliu.taskflow.sdk.workflow.def.tasks中Task的子类

修饰符和类型	类	说明
class	DoWhile	do while 可以在循环中执行一组任务，直到条件不再满足 例如：${workflow.input.loopCount} 为循环遍历条件表达式
class	Dynamic	Wait task
class	DynamicFork
class	Event	Task to publish Events to external queuing systems like SQS, NATS, AMQP etc.
class	For	for 循环遍历表达式: ${workflow.input.elements} 循环体获取元素: ${eachNameRef.output.element} 循环体获取索引下标: ${eachNameRef.output.index}
class	ForkFor	示例数据:elements: [A,B,C] 遍历数组原数，并行调用任务
class	ForkJoin	ForkJoin task 数据定义示例：
class	Http	Wait task
class	Javascript	JQ Transformation task See https://stedolan.github.io/jq/ for how to form the queries to parse JSON payloads
class	Join
class	JQ	JQ Transformation task See https://stedolan.github.io/jq/ for how to form the queries to parse JSON payloads
class	KafkaEvent	kafka 事件包装器
class	SetVariable
class	SubWorkflow
class	Switch	+----------------------+ | switch (expression) | +----------------------+ | v +----------------------+ | case 张三 | +----------------------+ | v +----------------------+ | do something task | +----------------------+ | v +----------------------+ | default: | +----------------------+ | v +----------------------+ | do something task | +----------------------+
class	Terminate
class	Wait	Wait task
class	WorkTask	Workflow task executed by a worker 自定义工作节点

返回Task的cn.feiliu.taskflow.sdk.workflow.def.tasks中的方法

修饰符和类型	方法	说明
Task[][]	ForkJoin.getForkedTasks()
static Task<?>	TaskRegistry.getTask(FlowTask workTask)

返回变量类型为Task的类型的cn.feiliu.taskflow.sdk.workflow.def.tasks中的方法

修饰符和类型	方法	说明
Map<String,List<Task<?>>>	Switch.getBranches()
List<Task<?>>	Switch.getDefaultTasks()
List<? extends Task>	DoWhile.getLoopTasks()
List<Task<?>>	DynamicForkInput.getTasks()

参数类型为Task的cn.feiliu.taskflow.sdk.workflow.def.tasks中的方法

修饰符和类型	方法	说明
DoWhile	DoWhile.childTask(Task<?> task)
For	For.childTask(Task<?> task)
ForkFor	ForkFor.childTask(Task<?> task)
Switch	Switch.defaultCase(Task<?>... tasks)
Switch	Switch.switchCase(String caseValue, Task... tasks)

类型变量类型为Task的cn.feiliu.taskflow.sdk.workflow.def.tasks中的方法参数

修饰符和类型	方法	说明
Switch	Switch.decisionCases(Map<String,List<Task<?>>> branches)
Switch	Switch.defaultCase(List<Task<?>> defaultTasks)
static void	TaskRegistry.register(String taskType, Class<? extends Task> taskImplementation)
void	DynamicForkInput.setTasks(List<Task<?>> tasks)

参数类型为Task的cn.feiliu.taskflow.sdk.workflow.def.tasks中的构造器

构造器	说明
ForkJoin(String taskReferenceName, Task<?>[]... forkedTasks)	execute task specified in the forkedTasks parameter in parallel.

类型变量类型为Task的cn.feiliu.taskflow.sdk.workflow.def.tasks中的构造器参数

构造器	说明
DynamicForkInput(List<Task<?>> tasks, Map<String,Object> inputs)