Open-Starter-Executor

一个支持任务并发执行的组件

🍪 快速开始

欢迎阅读 Open-Starter-Executor 文档！

如果你有任何与 Open-Starter-Executor 相关的问题，欢迎随时在 GitHub Discussions 上向我们的社区寻求帮助。

1. 添加 Maven 依赖

<dependency>
    <groupId>com.saucesubfresh</groupId>
    <artifactId>open-starter-executor</artifactId>
    <version>1.0.5</version>
</dependency>

2. 配置执行器相关参数

com:
  saucesubfresh:
    executor:
      timeout: 3 #超时时间

3. 使用案例

节选自 Open-Job

private void runTask(JobThreadQueueNode jobThreadQueueNode){
    taskExecutor.execute(jobThreadQueueNode, ((queueNode, isStop) -> {
        if (isStop){
            ResponseWriter responseWriter = queueNode.getResponseWriter();
            MessageResponseBody responseBody = queueNode.getResponseBody();
            responseBody.setMsg("job not executed in the job queue, killed.");
            responseBody.setStatus(ResponseStatus.ERROR);
            responseWriter.write(responseBody);
        }else {
            execute(queueNode);
        }
    }));
}