我有一个用例,其中出现了一些消息,每个消息都会触发一组任务,其中一些可能相互依赖,即。TaskD 需要 TaskA 和 TaskB 的结果,而 TaskC 独立于它们的任务,可以并行运行。
每条消息的任务和依赖关系可能会有所不同,可以根据消息类型进行配置。要求必须完成所有任务才能存储最终处理结果。
一些用于依赖管理的伪配置。
[msgType=aa]
- 任务A
- 任务B
- 任务C
- 任务D,依赖=任务A,任务B
我正在使用 Java 8 和 spring-boot。你能建议我用最好的方法干净地解决这个问题reactor
吗?reactor
适合这里吗?