third_codes/PowerJob
1
0
Fork 1
mirror of https://github.com/PowerJob/PowerJob.git synced 2025-07-17 00:00:04 +08:00
Code Issues Packages Projects Releases Wiki Activity

feat: define ProcessorFactory

Browse Source
This commit is contained in:
tjq 2023-01-17 22:05:48 +08:00
parent fbd75a6ec7
commit 2982410d80
2 changed files with 7 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
powerjob-worker/src/main/java/tech/powerjob/worker/extension/processor/ProcessorBean.java
View File

@ -6,7 +6,7 @@ import lombok.experimental.Accessors;
import tech.powerjob.worker.core.processor.sdk.BasicProcessor; import tech.powerjob.worker.core.processor.sdk.BasicProcessor;
/** /**
* 处理器对象，理论上只需要返回 BasicProcessor，但为了扩展性还是选择封装为对象 * 处理器对象
* *
* @author tjq * @author tjq
* @since 2023/1/17 * @since 2023/1/17
@ -20,4 +20,9 @@ public class ProcessorBean {
* 真正用来执行逻辑的处理器对象 * 真正用来执行逻辑的处理器对象
*/ */
private transient BasicProcessor processor; private transient BasicProcessor processor;
/**
* 加载该处理器对象的 classLoader，可空，空则使用 {@link Object#getClass()#getClassLoader() 代替}
*/
private transient ClassLoader classLoader;
} }

2
powerjob-worker/src/main/java/tech/powerjob/worker/extension/processor/ProcessorFactory.java
View File

@ -13,7 +13,7 @@ public interface ProcessorFactory {
* 根据处理器定义构建处理器对象 * 根据处理器定义构建处理器对象
* 注意：Processor 为单例对象，即 PowerJob 对每一个 ProcessorBean 只调用一次 build 方法 * 注意：Processor 为单例对象，即 PowerJob 对每一个 ProcessorBean 只调用一次 build 方法
* @param processorDefinition 处理器定义 * @param processorDefinition 处理器定义
* @return ProcessorBean * @return null or ProcessorBean
*/ */
ProcessorBean build(ProcessorDefinition processorDefinition); ProcessorBean build(ProcessorDefinition processorDefinition);
} }