🎡执行方法
你可以在Springboot/Spring体系中的任何被Spring上下文管理的类中进行注入FlowExecutor
。
FlowExecutor
有多个重载方法。
# 返回类型为LiteflowResponse
//参数为流程ID,无初始流程入参,上下文类型为默认的DefaultContext
public LiteflowResponse execute2Resp(String chainId)
//第一个参数为流程ID,第二个参数为流程入参。上下文类型为默认的DefaultContext
public LiteflowResponse execute2Resp(String chainId, Object param);
//第一个参数为流程ID,第二个参数为流程入参,后面可以传入多个上下文class
public LiteflowResponse execute2Resp(String chainId, Object param, Class<?>... contextBeanClazzArray)
//第一个参数为流程ID,第二个参数为流程入参,后面可以传入多个上下文的Bean
public LiteflowResponse execute2Resp(String chainId, Object param, Object... contextBeanArray)
建议
在这里,官方只推荐你用第3,4个方法,前面2个因为是默认上下文,可以用于测试场景,在生产场景中尽量别用默认上下文。
# 返回类型为Future
public Future<LiteflowResponse> execute2Future(String chainId, Object param, Class<?>... contextBeanClazzArray)
如果调用这个方法,那就是无阻塞的,想要拿到response,请用得到的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)
上次更新: 2023/08/04, 17:02:03