package tech.powerjob.worker.test.processors.demo;
|
|
import tech.powerjob.worker.core.processor.ProcessResult;
|
import tech.powerjob.worker.core.processor.TaskContext;
|
import tech.powerjob.worker.core.processor.TaskResult;
|
import tech.powerjob.worker.core.processor.sdk.BroadcastProcessor;
|
|
import java.util.List;
|
|
/**
|
* 示例-广播执行处理器
|
*
|
* @author tjq
|
* @since 2020/4/15
|
*/
|
public class BroadcastProcessorDemo implements BroadcastProcessor {
|
|
@Override
|
public ProcessResult preProcess(TaskContext taskContext) throws Exception {
|
// 预执行，会在所有 worker 执行 process 方法前调用
|
return new ProcessResult(true, "init success");
|
}
|
|
@Override
|
public ProcessResult process(TaskContext context) throws Exception {
|
// 撰写整个worker集群都会执行的代码逻辑
|
return new ProcessResult(true, "release resource success");
|
}
|
|
@Override
|
public ProcessResult postProcess(TaskContext taskContext, List<TaskResult> taskResults) throws Exception {
|
|
// taskResults 存储了所有worker执行的结果（包括preProcess）
|
|
// 收尾，会在所有 worker 执行完毕 process 方法后调用，该结果将作为最终的执行结果在
|
return new ProcessResult(true, "process success");
|
}
|
|
}
|
