程序包 cn.feiliu.taskflow.sdk.workflow.executor.task

类 DynamicForkWorker

java.lang.Object

cn.feiliu.taskflow.sdk.workflow.executor.task.DynamicForkWorker

所有已实现的接口:

Worker

public class DynamicForkWorker
extends Object
implements Worker

字段概要

从接口继承的字段 cn.feiliu.taskflow.sdk.worker.Worker

logger

构造器概要

构造器

构造器	说明
DynamicForkWorker(String name, Function<Object,DynamicForkInput> workerMethod, int pollingInterval)

方法概要

修饰符和类型	方法	说明
TaskExecResult	execute(ExecutingTask task)	Executes a task and returns the updated task.
int	getPollingInterval()	Override this method to change the interval between polls.
String	getTaskDefName()	Retrieve the name of the task definition the worker is currently working on.

从类继承的方法 java.lang.Object

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

从接口继承的方法 cn.feiliu.taskflow.sdk.worker.Worker

getBatchPollTimeoutInMS, getIdentity, leaseExtendEnabled, onErrorUpdate, paused

构造器详细资料

DynamicForkWorker

public DynamicForkWorker(String name,
                         Function<Object,DynamicForkInput> workerMethod,
                         int pollingInterval)

方法详细资料

getTaskDefName

public String getTaskDefName()

从接口复制的说明: Worker

Retrieve the name of the task definition the worker is currently working on.

指定者:

getTaskDefName 在接口中 Worker

返回:

the name of the task definition.

execute

public TaskExecResult execute(ExecutingTask task)
                       throws Throwable

从接口复制的说明: Worker

Executes a task and returns the updated task.

指定者:

execute 在接口中 Worker

参数:

task - Task to be executed.

返回:

the TaskExecResult object If the task is not completed yet, return with the status as IN_PROGRESS.

抛出:

Throwable

getPollingInterval

public int getPollingInterval()

从接口复制的说明: Worker

Override this method to change the interval between polls.

指定者:

getPollingInterval 在接口中 Worker

返回:

interval in millisecond at which the server should be polled for worker tasks.