Dapr Workflow 1.14版本中Activity并行执行问题的分析与解决

问题背景

在Dapr Workflow 1.14版本中，开发团队发现了一个关于Activity并行执行的严重问题。当使用WhenAll策略同时调度多个Activity时，这些Activity并没有按照预期并行执行，而是变成了顺序执行。这个问题在启用新的调度器提醒功能后尤为明显。

问题现象

测试场景中设置了20个Activity的并行执行：

• 前10个Activity使用SlowActivity（执行时间3秒）
• 后10个Activity使用VerySlowActivity（执行时间10秒）

在1.14版本中观察到：

1. 所有Activity的调度时间戳相同（证明是同时调度的）
2. 但实际激活时间却呈现严格的顺序模式：
   • SlowActivity之间间隔3秒
   • VerySlowActivity之间间隔10秒
3. 更严重的是，当运行多个工作流实例时，Activity执行变成了全局串行

技术分析

这个问题源于新的调度器提醒机制的实现方式。在1.14版本中：

1. 调度器采用了过于保守的并发控制策略
2. 不仅限制了单个工作流实例内的Activity并发
3. 还错误地将并发限制扩展到了整个工作流类型层面
4. 导致不同工作流实例间的Activity也无法并行执行

解决方案

开发团队在1.14版本中修复了这个问题，主要改进包括：

1. 修正了调度器的并发控制逻辑
2. 确保WhenAll策略能够真正实现并行调度
3. 移除了不必要的工作流类型级别并发限制
4. 恢复了Activity执行的预期并行行为

影响与建议

这个问题对以下场景影响较大：

• 需要高并发的Activity执行
• 使用WhenAll策略的复杂工作流
• 多个工作流实例同时运行的场景

建议用户升级到修复后的1.14版本，以获得正确的并行执行行为。对于性能敏感的应用，建议进行升级后的验证测试。

总结

Dapr Workflow作为分布式工作流引擎，正确的并行执行语义至关重要。1.14版本中的这个修复确保了系统在高并发场景下的表现符合预期，为复杂业务流程提供了可靠的基础设施支持。