LiteFlow LiteFlow
💒首页
  • v2.13.2(当前版本)
  • What's New

    • 🌈What' s New In LiteFlow v2.13.2?
  • 历史版本

    • v2.12.X
    • v2.11.X
    • v2.10.X
    • v2.9.X
    • v2.8.X
  • 升级指南

    • 🌈2.13.0升级指南
    • 2.12.4升级指南
    • 2.12.0升级指南
    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
👑LF CLUB社区
  • 常见问题
  • 专题解释

    • 如何理解上下文这个概念?
    • Slot是一个什么样的概念,在框架中起到什么样的作用?
💖赞助
🧩插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
👥加入群聊
🧤谁在使用
  • Gitee (opens new window)
  • GitCode (opens new window)
  • Github (opens new window)

广告采用随机轮播方式显示 ❤️成为赞助商
💒首页
  • v2.13.2(当前版本)
  • What's New

    • 🌈What' s New In LiteFlow v2.13.2?
  • 历史版本

    • v2.12.X
    • v2.11.X
    • v2.10.X
    • v2.9.X
    • v2.8.X
  • 升级指南

    • 🌈2.13.0升级指南
    • 2.12.4升级指南
    • 2.12.0升级指南
    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
👑LF CLUB社区
  • 常见问题
  • 专题解释

    • 如何理解上下文这个概念?
    • Slot是一个什么样的概念,在框架中起到什么样的作用?
💖赞助
🧩插件
🔥PPT
  • 项目介绍
  • 项目成员
  • 更新记录
  • 参与开发
👥加入群聊
🧤谁在使用
  • Gitee (opens new window)
  • GitCode (opens new window)
  • Github (opens new window)
  • LiteFlow介绍
  • 项目特性
  • 安装和集成

  • 规则文件

  • 用代码动态构造规则

  • 使用详细指南

    • 开启和关闭
    • 同步异步编排
    • 执行器
      • 返回类型为LiteflowResponse
      • 返回类型为Slot接口的子类
      • 返回类型为Future
    • 数据槽
    • 普通组件
    • 条件组件
    • 脚本组件
    • 声明式组件
    • 前置后置组件
    • 组件标签
    • 子流程
    • 隐式子流程
    • 私有投递
    • 组件重试
    • 平滑热刷新
    • 组件切面
    • 异常处理机制
    • 步骤打印
    • 不同格式规则加载
    • When异步线程池
    • 自定义组件执行器
    • 简单监控
  • 示例工程

  • 性能表现
  • v2.6.X文档
  • 使用详细指南
铂赛东
2022-06-01
目录

执行器

执行器FlowExecutor用来执行一个流程,三种用法。

# 返回类型为LiteflowResponse

其中最经常用到的有3个方法:

//参数为流程ID,无初始流程入参
public LiteflowResponse<DefaultSlot> execute2Resp(String chainId)
//第一个参数为流程ID,第二个参数为流程入参。其中流程入参可以在组件中通过this.getSlot().getRequestData()来获得。
public LiteflowResponse<DefaultSlot> execute2Resp(String chainId, Object param);
//第一个参数为流程ID,第二个参数为流程入参,第三个参数为自定义的Slot类型
public LiteflowResponse<T> execute2Resp(String chainId, Object param, Class<T> slotClazz)

如果你不定义自己的Slot,那么前2个能满足,第三个适用于你定义了自己的Slot类型的场景。

这里强烈推荐在业务系统中实现属于自己的Slot。具体原因和详情请参考数据槽。

你可以通过LiteflowResponse中的isSuccess()方法来判断链路是否执行成功。

这三个执行方法是不会抛出异常的,如果执行的链路有错误,你可以通过LiteflowResponse的getCause方法来获得。

# 返回类型为Slot接口的子类

同样的,经常用到的也有3个接口

//参数为流程ID,无初始流程入参
public DefaultSlot execute(String chainId) throws Exception;
//第一个参数为流程ID,第二个参数为流程入参。其中流程入参可以在组件中通过this.getSlot().getRequestData()来获得。
public DefaultSlot execute(String chainId,Object param) throws Exception;
//第一个参数为流程ID,第二个参数为流程入参,第三个参数为自定义的Slot类型
public <T extends Slot> T execute(String chainId, Object param, Class<T> slotClazz) throws Exception

在这种执行接口中,如果链路有错,会直接抛出来。

关于Slot,想要了解更多,请参考数据槽。

# 返回类型为Future

LiteFlow从2.6.13开始支持了执行器层面的异步,支持返回future。

//第一个参数为流程ID,第二个参数为流程入参,第三个参数为自定义的Slot类型
public <T extends Slot> Future<LiteflowResponse<T>> execute2Future(String chainId, Object param, Class<T> slotClazz)

如果调用这个方法,那就是无阻塞的,想要拿到reponse,请用得到的future.get()就可以了。

同时,主执行器在这个模式下的线程数和线程池也可以自定义,具体配置如下,LiteFlow已经设置了预设值,你也可自己定义。

liteflow.main-executor-works=64
liteflow.main-executor-class=com.yomahub.liteflow.thread.LiteFlowDefaultMainExecutorBuilder

如果你定义了自定义线程池,你需新建一个类,然后实现ExecutorBuilder接口:

public class CustomThreadBuilder implements ExecutorBuilder {
    @Override
    public ExecutorService buildExecutor() {
        return Executors.newCachedThreadPool();
    }
}
帮助我们改善此文档 (opens new window)
上次更新: 2022/10/07, 00:22:18
同步异步编排
数据槽

← 同步异步编排 数据槽→

Theme by Vdoing | Copyright © 2020-2025 铂赛东 | MIT License
沪ICP备18012955号-2
  • 跟随系统
  • 浅色模式
  • 深色模式
  • 阅读模式