执行器
执行器FlowExecutor
用来执行一个流程,三种用法。
# 返回类型为LiteflowResponse
其中最经常用到的有3个方法:
//参数为流程ID,无初始流程入参,返回类型为默认上下文泛型的Response
public LiteflowResponse<DefaultContext> execute2Resp(String chainId)
//第一个参数为流程ID,第二个参数为流程入参。其中流程入参可以在组件中通过this.getRequestData()来获得。
public LiteflowResponse<DefaultContext> execute2Resp(String chainId, Object param);
//第一个参数为流程ID,第二个参数为流程入参,第三个参数为自定义的上下文Bean类型
public <T> LiteflowResponse<T> execute2Resp(String chainId, Object param, Class<T> contextBeanClazz)
如果你不定义自己的上下文Bean,那么前2个能满足,LiteFlow提供了默认的上下文DefaultContext
。但是这个上下文是弱类型的。所以对于正常的业务,请使用第三个接口。前2个在一些简单的场景和测试场景中可以使用。
第三个适用于你定义了自己的上下文Bean的场景。适用于大多数的业务,推荐使用。
并且这里强烈推荐在业务系统中实现属于自己的上下文Bean。详情请参考数据上下文。
提示
你可以通过LiteflowResponse
中的isSuccess()
方法来判断链路是否执行成功。
这三个执行方法是不会抛出异常的,如果执行的链路有错误,你可以通过LiteflowResponse
的getCause
方法来获得。如要抛出异常,请自行抛出。
关于LiteflowResponse
的详细描述请参考Response对象。
# 返回类型为上下文Bean
同样的,经常用到的也有3个接口
//参数为流程ID,无初始流程入参
public DefaultContext execute(String chainId) throws Exception;
//第一个参数为流程ID,第二个参数为流程入参。其中流程入参可以在组件中通过this.getRequestData()来获得。
public DefaultContext execute(String chainId,Object param) throws Exception;
//第一个参数为流程ID,第二个参数为流程入参,第三个参数为自定义的上下文类型
public <T> T execute(String chainId, Object param, Class<T> contextBeanClazz) throws Exception
在这种执行接口中,如果链路有错,会直接抛出错误来。
关于上下文Bean,想要了解更多,请参考数据上下文。
# 返回类型为Future
LiteFlow从2.6.13
开始支持了执行器层面的异步,支持返回future。
//第一个参数为流程ID,第二个参数为流程入参,第三个参数为自定义的上下文Bean类型
public <T> Future<LiteflowResponse<T>> execute2Future(String chainId, Object param, Class<T> contextBeanClazz)
如果调用这个方法,那就是无阻塞的,想要拿到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