4

我有一个用例,其中出现了一些消息,每个消息都会触发一组任务,其中一些可能相互依赖,即。TaskD 需要 TaskA 和 TaskB 的结果,而 TaskC 独立于它们的任务,可以并行运行。

每条消息的任务和依赖关系可能会有所不同,可以根据消息类型进行配置。要求必须完成所有任务才能存储最终处理结果。

一些用于依赖管理的伪配置。

[msgType=aa]

  • 任务A
  • 任务B
  • 任务C
  • 任务D,依赖=任务A,任务B

我正在使用 Java 8 和 spring-boot。你能建议我用最好的方法干净地解决这个问题reactor吗?reactor适合这里吗?

4

0 回答 0