Skip to content

Commit 002cd2a

Browse files
author
lanzhengjian
committed
1.并行网关支持嵌套
2.修复并行网关最多支持两个分支问题 3.支持重写线程池、使用虚拟线程池 4.完善分支合并逻辑,添加可重写的锁机制 5.修复并行网关数据合并缺失问题
1 parent 4dad219 commit 002cd2a

File tree

21 files changed

+2346
-225
lines changed

21 files changed

+2346
-225
lines changed

CHANGELOG.md

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,9 @@
33

44
All notable changes to this project will be documented in this file.
55

6+
## [1.2.1] - 2025-11-17
7+
- Fix v1.2.0 release issues
8+
69
## [1.2.0] - 2024-11-21
710

811
Support plugin extension function

README.md

Lines changed: 21 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -250,10 +250,27 @@ LogicFlow 是一款流程图编辑框架,提供了一系列流程图交互、
250250

251251
为了提高Turbo的易扩展性,我们提供了插件机制,通过插件机制,可以扩展节点类型、表达式计算规则以及id生成规则。
252252

253-
为更好地回应社区伙伴的需求,我们推出了并行网关插件,不仅为流程引擎赋予并行执行能力,还可作为插件开发的参考样例,供大家借鉴。
254-
* 更新日志:[更新日志](./CHANGELOG.md)
255-
* 插件开发文档:[插件开发文档](./docs/PluginDevelopGuide.md)
256-
* 并行网关插件文档:[并行网关插件文档](./docs/Parallel&InclusiveGateway.md)
253+
为更好地回应社区伙伴的需求,我们推出了**并行网关&包容网关插件**,不仅为流程引擎赋予多分支并行执行能力,还可作为插件开发的参考样例,供大家借鉴。
254+
255+
### 并行网关&包容网关插件 (parallel-plugin)
256+
257+
**最新版本**: 1.0.1 (2025-11-17)
258+
259+
**核心功能**
260+
-**并行网关 (ParallelGateway)**:支持多分支并行执行,所有分支完成后汇聚
261+
-**包容网关 (InclusiveGateway)**:支持条件化的多分支并行执行,满足条件的分支执行后汇聚
262+
-**嵌套并行网关**:支持在并行分支内再次创建并行网关,实现多层并行编排
263+
-**灵活的汇聚策略**:支持 JoinAll(全部汇聚)、AnyOne(任一汇聚)、Custom(自定义)
264+
-**可配置的线程池**:支持通过配置文件或自定义 Bean 调整线程池参数
265+
266+
**相关文档**
267+
* 📖 [并行网关&包容网关使用指南](docs/parallel/Parallel&InclusiveGateway.md)
268+
* 📖 [线程池配置指南](docs/parallel/ThreadPoolConfiguration.md)
269+
* 📋 [更新日志](docs/parallel/CHANGELOG.md)
270+
* 🔧 [插件开发文档](./docs/PluginDevelopGuide.md)
271+
272+
**引擎更新日志**
273+
* [Engine CHANGELOG](./CHANGELOG.md)
257274

258275
## 7. 联系我们
259276
### 加入微信群

docs/Parallel&InclusiveGateway.md

Lines changed: 0 additions & 110 deletions
This file was deleted.

docs/parallel/CHANGELOG.md

Lines changed: 40 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,40 @@
1+
# Change Log
2+
3+
All notable changes to this project will be documented in this file.
4+
5+
## [1.0.1] - 2025-11-14
6+
7+
### Added
8+
- Support for nested parallel gateways
9+
- Configurable thread pool with flexible options (file-based or custom Bean)
10+
- **Concurrency safety mechanism for branch merging** - Prevents data overwrite issues when multiple branches arrive concurrently
11+
- Default local lock implementation using `ReentrantLock` (single-machine deployment)
12+
- Extensible lock interface supporting custom implementations (e.g., Redis distributed lock)
13+
- Automatic retry mechanism when lock acquisition fails (configurable retry interval and max retry times)
14+
15+
### Changed
16+
- Thread pool default core size increased from 1 to 10
17+
- Engine dependency changed to version range `[1.2.1,)` allowing newer versions
18+
- Enhanced POM configuration for standalone Maven Central publishing
19+
20+
### Fixed
21+
- Fixed incorrect flow completion status in nested parallel gateway scenarios
22+
- Fixed MyBatis interceptor unable to extract entity from `updateById` wrapped Map parameters
23+
- Fixed `ParallelNodeInstanceHandler` unable to handle `updateById` and `deleteById` operations
24+
25+
### Documentation
26+
- Added `ThreadPoolConfiguration.md` for detailed thread pool configuration guide
27+
- Added `ConcurrencySafety.md` for branch merging lock mechanism documentation
28+
- Updated `Parallel&InclusiveGateway.md` with quick start guide, nested gateway documentation, and concurrency safety guide
29+
- Cross-referenced documentation for better navigation
30+
31+
### Support
32+
- turbo 1.2.1+
33+
34+
## [1.0.0] - 2025-10-29
35+
36+
### Added
37+
- Support parallel gateway plugin
38+
39+
### Support
40+
- turbo 1.2.0+

0 commit comments

Comments
 (0)