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

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

    • v2.10.X
    • v2.9.X
    • v2.8.X
    • v2.7.X
    • v2.6.X
  • 升级指南

    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
  • 常见问题
  • 专题解释

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

    • TLog-轻量级的分布式日志追踪神器 (opens new window)
    • ERD ONLINE-开箱即用的数据库建模、产品版本管理软件 (opens new window)
    • Forest-更轻量、更简单实用的HTTP客户端框架 (opens new window)

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

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

    • v2.10.X
    • v2.9.X
    • v2.8.X
    • v2.7.X
    • v2.6.X
  • 升级指南

    • 升级到2.9.3说明
    • 升级到2.9.X说明
    • 升级到2.8.X说明
    • 升级到2.7.X说明
  • 常见问题
  • 专题解释

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

    • TLog-轻量级的分布式日志追踪神器 (opens new window)
    • ERD ONLINE-开箱即用的数据库建模、产品版本管理软件 (opens new window)
    • Forest-更轻量、更简单实用的HTTP客户端框架 (opens new window)
  • 🍤LiteFlow简介
  • 🍓项目特性
  • 🧁环境支持

    • ☕️JDK支持度
    • 🌿Springboot支持度
    • 🌱Spring的支持度
  • 🍟快速开始(Hello world)

    • 🍄说明
    • 🌿Springboot场景安装运行

      • 🧬依赖
      • ⚙️配置
      • 🛫执行
    • 🌱Spring场景安装运行

      • 🧬依赖
      • ⚙️配置
      • 🛫执行
    • 🌵其他场景安装运行

      • 🍄说明
      • 🧬依赖
      • ⚙️配置
      • 🛫执行
  • 🍢配置项

    • 🍄说明
    • 🌿Springboot下的配置项
    • 🌱Spring下的配置项
    • 🌵其他场景代码设置配置项
  • 🗂规则文件

    • 📔规则文件格式
    • 📕本地规则文件配置
    • 📗ZK规则文件配置源
    • 📘SQL数据库配置源
    • 📋Nacos配置源
    • 🗄Etcd配置源
    • 📜Apollo配置源
    • 📑Redis配置源

      • 配置说明
      • 轮询模式配置
      • 订阅模式配置
    • 📙自定义配置源
  • 🔗常规组件

    • 📎普通组件
    • ✂️选择组件
    • 📌条件组件
    • 🧬次数循环组件
    • ⛓条件循环组件
    • ⌛️迭代循环组件
    • 🧿退出循环组件
  • 🧩EL规则的写法

    • 🍄说明
    • 🌴串行编排
    • 🎋并行编排
    • 🌾选择编排
    • 🌵条件编排
    • 🌳循环编排
    • 🎃捕获异常表达式
    • 🍄与或非表达式
    • 🍁使用子流程
    • 🍂使用子变量
    • 💐复杂编排例子
    • 🌻关于分号
    • 🌰关于注释
    • 🐚组件名包装
    • 🔆验证规则
  • 🌮数据上下文

    • 🍄说明
    • 🌯数据上下文的定义和使用
    • 🪶用初始化好的上下文传入
  • 🛩执行器

    • 🍄说明
    • 🎡执行方法
    • 🎢流程入参
    • 🎈LiteflowResponse对象
  • 🍋脚本组件

    • 🌭脚本语言介绍
    • 🍫脚本语言种类

      • 🥏Groovy脚本引擎
      • 🧀Javascript脚本引擎
      • ☕️Java脚本引擎
      • 🥞QLExpress脚本引擎
      • 🍧Python脚本引擎
      • 🍝Lua脚本引擎
      • 🥐Aviator脚本引擎
    • 🍣脚本与Java进行交互
    • 🍱多脚本语言混合共存
    • 🌯文件脚本的定义
    • 🍘动态刷新脚本
  • 🍇声明式组件

    • 🥭什么叫声明式组件
    • 🧅类级别式声明
    • 🥥方法级别式声明
  • 🎲用代码动态构造规则

    • 🍄说明
    • 🎯如何构造
  • 🎨高级特性

    • 🍒前置和后置组件
    • 🍌本地规则文件监听
    • 🥠替补组件
    • 🍉组件参数
    • 🍑组件别名
    • 🍍组件标签
    • 🥝组件事件回调
    • 🐋组件回滚
    • 🥑隐式子流程
    • 🍕私有投递
    • 🍣组件重试
    • 🥦异步循环模式
      • 使用方法
      • 例子
      • 使用说明
    • ⏱️超时控制
    • 🍖平滑热刷新
    • 🍪组件切面
    • 🍡步骤信息
    • 🧊异常
    • 🧇打印信息详解
    • 🧁自定义请求Id
    • 🌭不同格式规则加载
    • 🥗异步线程池自定义
    • 🍿自定义组件执行器
    • 🍥简单监控
    • 🧉XML的DTD
  • ⛱测试用例以及示例

    • 🪁测试用例
    • 🪀DEMO案例
  • 🪂性能表现
  • v2.11.X文档
  • 🎨高级特性
铂赛东
2023-08-14
目录

🥦异步循环模式

LiteFlow从2.11.0版本起,支持了循环表达式的异步模式,使得各个循环表达式的循环子项可以异步执行。

# 使用方法

对于LiteFlow中的次数循环表达式、条件循环表达式以及迭代循环表达式等循环表达式,可以使用parallel子关键字(默认为false)来配置循环子项的执行方式,使其成为异步模式的循环表达式(所谓异步模式,就是各个循环子项之间并行执行)。

如果parallel子关键字设置为true,表示各循环子项之间并行执行,否则各循环子项之间串行执行。


# 例子

对于次数循环表达式,可以这样配置,使其各个循环子项并行执行:

<chain name="chain1">
   FOR(2).parallel(true).DO(THEN(a,b,c));
</chain>

如果使用上述配置,每个循环子项本身的执行方式保持不变,只是各个循环子项之间的执行方式变为并行执行,也就是chain1会并行执行两次THEN(a,b,c)。

对于条件循环表达式,可以这样配置,使其各个循环子项并行执行:

<chain name="chain6">
   WHILE(x).parallel(true).DO(THEN(a,b,c));
</chain>

对于迭代循环表达式,可以这样配置,使其各个循环子项并行执行:

<chain name="chain7">
   ITERATOR(x).parallel(true).DO(THEN(a,b,c));
</chain>

# 使用说明

  1. parallel子关键字只能用于次数循环表达式、条件循环表达式以及迭代循环表达式等循环表达式。
  2. 对于异步模式的条件循环表达式,会不断创建并行执行循环子项,直到条件不满足为止。
  3. 异步模式依然支持BREAK,当退出循环组件返回为true时,会停止向线程池提交新的任务,但是已经提交的任务会继续执行。循环组件会在所有已提交任务执行完毕后退出。
  4. 默认情况下,异步模式的下各循环子项会在liteFlow提供的默认异步循环线程池中执行,并且可以通过如下两个参数来控制默认线程池的workers数目和队列长度
    <!--配置默认线程池的worker数目-->
    liteflow.parallelLoop-max-workers=16
    <!--配置默认线程池的队列长度-->
    liteflow.parallelLoop-queue-limit=512
    
    当然,也可以通过自定义线程池来执行异步模式的循环子项,只需要在配置文件中进行如下配置即可,不过此时上述两个参数将不再生效。
    <!--用户可以直接指定自定义的线程池全类名的方式指定异步循环线程池-->
    liteflow.parallelLoop-executor-class=com.yomahub.liteflow.test.customThreadPool.CustomThreadBuilder
    
帮助我们改善此文档 (opens new window)
上次更新: 2023/08/27, 22:47:03
🍣组件重试
⏱️超时控制

← 🍣组件重试 ⏱️超时控制→

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