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

使用Task的程序包

程序包	说明
cn.feiliu.taskflow.sdk.workflow.def.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
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	SimpleTask	Workflow task executed by a worker
class	SubWorkflow
class	Switch	Switch Task
class	Terminate
class	Wait	Wait task

返回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中的方法

修饰符和类型	方法	说明
Switch	Switch.defaultCase(Task<?>... tasks)
DoWhile	DoWhile.loopOver(Task<?>... tasks)
For	For.loopOver(Task<?>... tasks)
ForkFor	ForkFor.loopOver(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中的构造器

构造器	说明
DoWhile(String taskReferenceName, int loopCount, Task<?>... tasks)	Similar to a for loop, run tasks for N times
DoWhile(String taskReferenceName, String expression, Task<?>... tasks)	Execute tasks in a loop determined by the condition set using condition parameter.
For(String taskReferenceName, String eachExpression, Task<?>... tasks)	Execute tasks in a loop determined by the condition set using condition parameter.
ForkFor(String taskReferenceName, String eachExpression, Task<?>... tasks)	Execute tasks in a loop determined by the condition set using condition parameter.
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)