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简介
  • 🍓项目特性
  • 🧁环境支持

  • 🍟快速开始(Hello world)

  • 🍢配置项

  • 🗂规则文件

  • 🔗常规组件

  • 🧩EL规则的写法

  • 🌮数据上下文

  • 🛩执行器

  • 🍋脚本组件

  • 🍇声明式组件

  • 🎲用代码动态构造规则

  • 🎨高级特性

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

  • 🪂性能表现
  • 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.parallel-max-workers=16
    <!--配置默认线程池的队列长度-->
    liteflow.parallel-queue-limit=512
    
    当然,也可以通过自定义线程池来执行异步模式的循环子项,只需要在配置文件中进行如下配置即可,不过此时上述两个参数将不再生效。
    <!--用户可以直接指定自定义的线程池全类名的方式指定异步循环线程池-->
    liteflow.parallel-loop-executor-class=com.yomahub.liteflow.test.customThreadPool.CustomThreadBuilder
    
帮助我们改善此文档 (opens new window)
上次更新: 2024/04/09, 18:39:17
🍣组件重试
⏱️超时控制

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

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