com.github.kfcfans.powerjob.worker.core.processor.sdk

类 BroadcastProcessor

java.lang.Object

com.github.kfcfans.powerjob.worker.core.processor.sdk.BroadcastProcessor

所有已实现的接口:

BasicProcessor

public abstract class BroadcastProcessor
extends Object
implements BasicProcessor

广播执行处理器，适用于广播执行

从以下版本开始:

2020/3/18

作者:

tjq

构造器概要

构造器

构造器和说明
BroadcastProcessor()

方法概要

限定符和类型	方法和说明
static ProcessResult	defaultResult(List<TaskResult> taskResults)
ProcessResult	postProcess(TaskContext context, List<TaskResult> taskResults) 在所有节点广播执行完成后执行，只会在一台机器执行一次
ProcessResult	preProcess(TaskContext context) 在所有节点广播执行前执行，只会在一台机器执行一次

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

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

从接口继承的方法 com.github.kfcfans.powerjob.worker.core.processor.sdk.BasicProcessor

process

构造器详细资料

BroadcastProcessor

public BroadcastProcessor()

方法详细资料

preProcess

public ProcessResult preProcess(TaskContext context)
                         throws Exception

在所有节点广播执行前执行，只会在一台机器执行一次

抛出:

Exception

postProcess

public ProcessResult postProcess(TaskContext context,
                                 List<TaskResult> taskResults)
                          throws Exception

在所有节点广播执行完成后执行，只会在一台机器执行一次

抛出:

Exception

defaultResult

public static ProcessResult defaultResult(List<TaskResult> taskResults)